`airflow.executors.debug_executor`¶

This module contains DebugExecutor that is a single process executor meaning it does not use multiprocessing.

Module Contents¶

class airflow.executors.debug_executor.DebugExecutor[source]¶

Bases: airflow.executors.base_executor.BaseExecutor

This executor is meant for debugging purposes. It can be used with SQLite.

It executes one task instance at time. Additionally to support working with sensors, all sensors mode will be automatically set to “reschedule”.

_terminated[source]¶

execute_async(self, *args, **kwargs)[source]¶: The method is replaced by custom trigger_task implementation.

sync(self)[source]¶

_run_task(self, ti)[source]¶

queue_task_instance(self, task_instance, mark_success=False, pickle_id=None, ignore_all_deps=False, ignore_depends_on_past=False, ignore_task_deps=False, ignore_ti_state=False, pool=None, cfg_path=None)[source]¶: Queues task instance with empty command because we do not need it.

trigger_tasks(self, open_slots)[source]¶

Triggers tasks. Instead of calling exec_async we just add task instance to tasks_to_run queue.

Parameters: open_slots – Number of open slots

end(self)[source]¶: When the method is called we just set states of queued tasks to UPSTREAM_FAILED marking them as not executed.

terminate(self)[source]¶

change_state(self, key, state)[source]¶

Was this entry helpful?