mirror of https://github.com/astral-sh/ruff
56 lines
2.1 KiB
Python
56 lines
2.1 KiB
Python
from __future__ import annotations
|
|
|
|
from airflow.hooks.filesystem import FSHook
|
|
from airflow.hooks.package_index import PackageIndexHook
|
|
from airflow.hooks.subprocess import SubprocessHook, SubprocessResult, working_directory
|
|
from airflow.operators.bash import BashOperator
|
|
from airflow.operators.datetime import BranchDateTimeOperator, target_times_as_dates
|
|
from airflow.operators.empty import EmptyOperator
|
|
from airflow.operators.latest_only import LatestOnlyOperator
|
|
from airflow.operators.python import (
|
|
BranchPythonOperator,
|
|
PythonOperator,
|
|
PythonVirtualenvOperator,
|
|
ShortCircuitOperator,
|
|
)
|
|
from airflow.operators.trigger_dagrun import TriggerDagRunLink, TriggerDagRunOperator
|
|
from airflow.operators.weekday import BranchDayOfWeekOperator
|
|
from airflow.sensors.date_time import DateTimeSensor, DateTimeSensorAsync
|
|
from airflow.sensors.external_task import (
|
|
ExternalTaskMarker,
|
|
ExternalTaskSensor,
|
|
ExternalTaskSensorLink,
|
|
)
|
|
from airflow.sensors.filesystem import FileSensor
|
|
from airflow.sensors.time_delta import TimeDeltaSensor, TimeDeltaSensorAsync, WaitSensor
|
|
from airflow.sensors.time_sensor import TimeSensor, TimeSensorAsync
|
|
from airflow.sensors.weekday import DayOfWeekSensor
|
|
from airflow.triggers.external_task import DagStateTrigger, WorkflowTrigger
|
|
from airflow.triggers.file import FileTrigger
|
|
from airflow.triggers.temporal import DateTimeTrigger, TimeDeltaTrigger
|
|
|
|
FSHook()
|
|
PackageIndexHook()
|
|
SubprocessHook(), SubprocessResult(), working_directory()
|
|
BashOperator()
|
|
BranchDateTimeOperator(), target_times_as_dates()
|
|
TriggerDagRunLink(), TriggerDagRunOperator()
|
|
EmptyOperator()
|
|
LatestOnlyOperator()
|
|
(
|
|
BranchPythonOperator(),
|
|
PythonOperator(),
|
|
PythonVirtualenvOperator(),
|
|
ShortCircuitOperator(),
|
|
)
|
|
BranchDayOfWeekOperator()
|
|
DateTimeSensor(), DateTimeSensorAsync()
|
|
ExternalTaskMarker(), ExternalTaskSensor(), ExternalTaskSensorLink()
|
|
FileSensor()
|
|
TimeSensor(), TimeSensorAsync()
|
|
TimeDeltaSensor(), TimeDeltaSensorAsync(), WaitSensor()
|
|
DayOfWeekSensor()
|
|
DagStateTrigger(), WorkflowTrigger()
|
|
FileTrigger()
|
|
DateTimeTrigger(), TimeDeltaTrigger()
|