code: func (engine *DockerTaskEngine) synchronizeState() {
  	engine.tasksLock.Lock()
  	defer engine.tasksLock.Unlock()
  	imageStates := engine.state.AllImageStates()
  	if len(imageStates) != 0 {
  		engine.imageManager.AddAllImageStates(imageStates)
  	}
  
  	tasks := engine.state.AllTasks()
  	tasksToStart := engine.filterTasksToStartUnsafe(tasks)
  	for _, task := range tasks {
  		task.InitializeResources(engine.resourceFields)
  	}
  
  	for _, task := range tasksToStart {
  		engine.startTask(task)
  	}
  
  	engine.saver.Save()
  }
docs: // synchronizeState explicitly goes through each docker container stored in
  // "state" and updates its KnownStatus appropriately, as well as queueing up
  // events to push upstream.