PythonSensor
Apache AirflowWaits for a Python callable to return True.
Access Instructions
Install the Apache Airflow provider package into your Airflow environment.
Import the module into your DAG file and instantiate it with your desired params.
Parameters
python_callableRequiredA reference to an object that is callable
op_kwargsa dictionary of keyword arguments that will get unpacked in your function
op_argsa list of positional arguments that will get unpacked when calling your callable
templates_dicta dictionary where the values are templates that will get templated by the Airflow engine sometime between __init__ and execute takes place and are made available in your callable’s context after the template has been applied.
Documentation
Waits for a Python callable to return True.
User could put input argument in templates_dict e.g templates_dict = {'start_ds': 1970} and access the argument by calling kwargs['templates_dict']['start_ds'] in the callable
See also
For more information on how to use this sensor, take a look at the guide: PythonSensor