airflow.executors.sequential_executor

SequentialExecutor

See also

For more information on how the SequentialExecutor works, take a look at the guide: Sequential Executor

Module Contents

Classes

SequentialExecutor

This executor will only run one task instance at a time, can be used
class airflow.executors.sequential_executor.SequentialExecutor[source]

Bases: airflow.executors.base_executor.BaseExecutor

This executor will only run one task instance at a time, can be used for debugging. It is also the only executor that can be used with sqlite since sqlite doesn't support multiple connections.

Since we want airflow to work out of the box, it defaults to this SequentialExecutor alongside sqlite as you first install it.

execute_async(self, key: airflow.models.taskinstance.TaskInstanceKey, command: airflow.executors.base_executor.CommandType, queue: Optional[str] = None, executor_config: Optional[Any] = None) → None[source]

This method will execute the command asynchronously.

Parameters

  • key -- Unique key for the task instance

  • command -- Command to run

  • queue -- name of the queue

  • executor_config -- Configuration passed to the executor.

sync(self) → None[source]

Sync will get called periodically by the heartbeat method. Executors should override this to perform gather statuses.

end(self)[source]

End the executor.

terminate(self)[source]

Terminate the executor is not doing anything.

Was this entry helpful?