Standard

apache-airflow-providers-standard

Airflow Standard Provider

Works with Airflow 2.11+
Install:
pip install apache-airflow-providers-standard==1.12.1

Airflow

2.11+

Python

>=3.10

Dependencies (2)

Show all Hide apache-airflow>=2.11.0 apache-airflow-providers-common-compat>=1.14.1

Connections (2)

Modules

O

BranchDateTimeOperator

Branches into one of two lists of tasks depending on the current datetime.

airflow.providers.standard.operators.datetime.BranchDateTimeOperator
O

BranchDayOfWeekOperator

Branches into one of two lists of tasks depending on the current day.

airflow.providers.standard.operators.weekday.BranchDayOfWeekOperator
O

BashOperator

Execute a Bash script, command or set of commands.

airflow.providers.standard.operators.bash.BashOperator
O

BranchExternalPythonOperator

A workflow can "branch" or follow a path after the execution of this task.

airflow.providers.standard.operators.python.BranchExternalPythonOperator
O

BranchPythonOperator

A workflow can "branch" or follow a path after the execution of this task.

airflow.providers.standard.operators.python.BranchPythonOperator
O

BranchPythonVirtualenvOperator

A workflow can "branch" or follow a path after the execution of this task in a virtual environment.

airflow.providers.standard.operators.python.BranchPythonVirtualenvOperator
O

ExternalPythonOperator

Run a function in a virtualenv that is not re-created.

airflow.providers.standard.operators.python.ExternalPythonOperator
O

PythonOperator

Base class for all Python operators.

airflow.providers.standard.operators.python.PythonOperator
O

PythonVirtualenvOperator

Run a function in a virtualenv that is created and destroyed automatically.

airflow.providers.standard.operators.python.PythonVirtualenvOperator
O

ShortCircuitOperator

Allows a pipeline to continue based on the result of a ``python_callable``.

airflow.providers.standard.operators.python.ShortCircuitOperator
O

EmptyOperator

Operator that does literally nothing.

airflow.providers.standard.operators.empty.EmptyOperator
O

TriggerDagRunOperator

Triggers a DAG run for a specified DAG ID.

airflow.providers.standard.operators.trigger_dagrun.TriggerDagRunOperator
O

LatestOnlyOperator

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

airflow.providers.standard.operators.latest_only.LatestOnlyOperator
O

SmoothOperator

Operator that logs a YouTube link to Sade song "Smooth Operator".

airflow.providers.standard.operators.smooth.SmoothOperator
O

ApprovalOperator

Human-in-the-loop Operator that has only 'Approval' and 'Reject' options.

airflow.providers.standard.operators.hitl.ApprovalOperator
O

HITLBranchOperator

BranchOperator based on Human-in-the-loop Response.

airflow.providers.standard.operators.hitl.HITLBranchOperator
O

HITLEntryOperator

Human-in-the-loop Operator that is used to accept user input through TriggerForm.

airflow.providers.standard.operators.hitl.HITLEntryOperator
O

HITLOperator

Base class for all Human-in-the-loop Operators to inherit from.

airflow.providers.standard.operators.hitl.HITLOperator
H

FSHook

Allows for interaction with an file server.

airflow.providers.standard.hooks.filesystem.FSHook
H

PackageIndexHook

Specify package indexes/Python package sources using Airflow connections.

airflow.providers.standard.hooks.package_index.PackageIndexHook
H

SubprocessHook

Hook for running processes with the ``subprocess`` module.

airflow.providers.standard.hooks.subprocess.SubprocessHook
S

DateTimeSensor

Waits until the specified datetime.

airflow.providers.standard.sensors.date_time.DateTimeSensor
S

DateTimeSensorAsync

Wait until the specified datetime occurs.

airflow.providers.standard.sensors.date_time.DateTimeSensorAsync
S

TimeDeltaSensor

Waits for a timedelta.

airflow.providers.standard.sensors.time_delta.TimeDeltaSensor
S

TimeDeltaSensorAsync

Deprecated. Use TimeDeltaSensor with deferrable=True instead.

airflow.providers.standard.sensors.time_delta.TimeDeltaSensorAsync
S

WaitSensor

A sensor that waits a specified period of time before completing.

airflow.providers.standard.sensors.time_delta.WaitSensor
S

TimeSensor

Waits until the specified time of the day.

airflow.providers.standard.sensors.time.TimeSensor
S

TimeSensorAsync

Deprecated. Use TimeSensor with deferrable=True instead.

airflow.providers.standard.sensors.time.TimeSensorAsync
S

DayOfWeekSensor

Waits until the first specified day of the week.

airflow.providers.standard.sensors.weekday.DayOfWeekSensor
S

BashSensor

Executes a bash command/script.

airflow.providers.standard.sensors.bash.BashSensor
S

PythonSensor

Waits for a Python callable to return True.

airflow.providers.standard.sensors.python.PythonSensor
S

FileSensor

Waits for a file or folder to land in a filesystem.

airflow.providers.standard.sensors.filesystem.FileSensor
S

ExternalTaskSensor

Waits for a different DAG, task group, or task to complete for a specific logical date.

airflow.providers.standard.sensors.external_task.ExternalTaskSensor
T

DagStateTrigger

Waits asynchronously for a dag to complete for a specific run_id.

airflow.providers.standard.triggers.external_task.DagStateTrigger
T

WorkflowTrigger

A trigger to monitor tasks, task group and dag execution in Apache Airflow.

airflow.providers.standard.triggers.external_task.WorkflowTrigger
T

FileDeleteTrigger

A trigger that fires exactly once after it finds the requested file and then delete the file.

airflow.providers.standard.triggers.file.FileDeleteTrigger
T

FileTrigger

A trigger that fires exactly once after it finds the requested file or folder.

airflow.providers.standard.triggers.file.FileTrigger
T

DateTimeTrigger

Trigger based on a datetime.

airflow.providers.standard.triggers.temporal.DateTimeTrigger
T

TimeDeltaTrigger

Create DateTimeTriggers based on delays.

airflow.providers.standard.triggers.temporal.TimeDeltaTrigger
T

HITLTrigger

A trigger that checks whether Human-in-the-loop responses are received.

airflow.providers.standard.triggers.hitl.HITLTrigger
D

@task.python

Wrap a function into an Airflow operator.

airflow.providers.standard.decorators.python.python_task
D

@task.bash

Wrap a function into a BashOperator.

airflow.providers.standard.decorators.bash.bash_task
D

@task.branch_external_python

Wrap a python function into a BranchExternalPythonOperator.

airflow.providers.standard.decorators.branch_external_python.branch_external_python_task
D

@task.branch

Wrap a python function into a BranchPythonOperator.

airflow.providers.standard.decorators.branch_python.branch_task
D

@task.branch_virtualenv

Wrap a python function into a BranchPythonVirtualenvOperator.

airflow.providers.standard.decorators.branch_virtualenv.branch_virtualenv_task
D

@task.external_python

Wrap a callable into an Airflow operator to run via a Python virtual environment.

airflow.providers.standard.decorators.external_python.external_python_task
D

@task.virtualenv

Wrap a callable into an Airflow operator to run via a Python virtual environment.

airflow.providers.standard.decorators.python_virtualenv.virtualenv_task
D

@task.sensor

Wrap a function into an Airflow operator.

airflow.providers.standard.decorators.sensor.sensor_task
D

@task.short_circuit

Wrap a function into an ShortCircuitOperator.

airflow.providers.standard.decorators.short_circuit.short_circuit_task
D

@task.stub

Define a stub task in the DAG.

airflow.providers.standard.decorators.stub.stub