airflow.providers.standard.operators.datetime
¶
模块内容¶
类¶
根据当前日期时间分支到两个任务列表之一。 |
函数¶
|
通过将上限和下限时间目标与 base_date 组合,确保它们是日期时间。 |
- class airflow.providers.standard.operators.datetime.BranchDateTimeOperator(*, follow_task_ids_if_true, follow_task_ids_if_false, target_lower, target_upper, use_task_logical_date=False, **kwargs)[源代码]¶
基类:
airflow.operators.branch.BaseBranchOperator
根据当前日期时间分支到两个任务列表之一。
有关如何使用此操作符的更多信息,请查看指南:BranchDateTimeOperator。
当
datetime.datetime.now()
介于target_upper
和target_lower
之间时,将返回 True 分支。- 参数
follow_task_ids_if_true (str | collections.abc.Iterable[str]) – 如果
datetime.datetime.now()
大于 target_lower 且小于 target_upper,则要跟踪的 task_id、task_group_id 或 task_ids 和/或 task_group_ids 的列表。follow_task_ids_if_false (str | collections.abc.Iterable[str]) – 如果
datetime.datetime.now()
小于 target_lower 或大于 target_upper,则要跟踪的 task_id、task_group_id 或 task_ids 和/或 task_group_ids 的列表。target_lower (datetime.datetime | datetime.time | None) – 目标下限。
target_upper (datetime.datetime | datetime.time | None) – 目标上限。
use_task_logical_date (bool) – 如果为
True
,则使用任务的逻辑日期与目标进行比较。逻辑日期对于回填很有用。如果为False
,则使用系统日期。