airflow.providers.standard.operators.latest_only¶

Contains an operator to run downstream tasks only for the latest scheduled DagRun.

Classes¶

LatestOnlyOperator

Skip tasks that are not running during the most recent schedule interval.

Module Contents¶

class airflow.providers.standard.operators.latest_only.LatestOnlyOperator(*, task_id, owner=DEFAULT_OWNER, email=None, email_on_retry=True, email_on_failure=True, retries=DEFAULT_RETRIES, retry_delay=DEFAULT_RETRY_DELAY, retry_exponential_backoff=False, max_retry_delay=None, start_date=None, end_date=None, depends_on_past=False, ignore_first_depends_on_past=DEFAULT_IGNORE_FIRST_DEPENDS_ON_PAST, wait_for_past_depends_before_skipping=DEFAULT_WAIT_FOR_PAST_DEPENDS_BEFORE_SKIPPING, wait_for_downstream=False, dag=None, params=None, default_args=None, priority_weight=DEFAULT_PRIORITY_WEIGHT, weight_rule=DEFAULT_WEIGHT_RULE, queue=DEFAULT_QUEUE, pool=None, pool_slots=DEFAULT_POOL_SLOTS, sla=None, execution_timeout=DEFAULT_TASK_EXECUTION_TIMEOUT, on_execute_callback=None, on_failure_callback=None, on_success_callback=None, on_retry_callback=None, on_skipped_callback=None, pre_execute=None, post_execute=None, trigger_rule=DEFAULT_TRIGGER_RULE, resources=None, run_as_user=None, map_index_template=None, max_active_tis_per_dag=None, max_active_tis_per_dagrun=None, executor=None, executor_config=None, do_xcom_push=True, multiple_outputs=False, inlets=None, outlets=None, task_group=None, doc=None, doc_md=None, doc_json=None, doc_yaml=None, doc_rst=None, task_display_name=None, logger_name=None, allow_nested_operators=True, **kwargs)[source]¶

Bases: airflow.providers.standard.operators.branch.BaseBranchOperator

Skip tasks that are not running during the most recent schedule interval.

If the task is run outside the latest schedule interval (i.e. run_type == DagRunType.MANUAL), all directly downstream tasks will be skipped.

Note that downstream tasks are never skipped if the given DAG_Run is marked as externally triggered.

Note that when used with timetables that produce zero-length or point-in-time data intervals (e.g., DeltaTriggerTimetable), this operator assumes each run is the latest and does not skip downstream tasks.

ui_color = '#e9ffdb'[source]¶

choose_branch(context)[source]¶

Abstract method to choose which branch to run.

Subclasses should implement this, running whatever logic is necessary to choose a branch and returning a task_id or list of task_ids.

Parameters:: context (airflow.sdk.definitions.context.Context) – Context dictionary as passed to execute()