This is an early-access feature and might change in incompatible ways in future Airflow versions. However this feature can be considered bug-free, and Airbnb has been using this feature in production since early 2020 and has significantly reduced their costs for heavy use of sensors.
Deferrable Operators are a more flexible way to achieve efficient long-running sensors, as well as allowing Operators to also achieve similar efficiency gains. If you are considering writing a new Smart Sensor, you may want to instead write it as a Deferrable Operator.
The smart sensor is a service (run by a builtin DAG) which greatly reduces Airflow’s infrastructure cost by consolidating multiple instances of small, light-weight Sensors into a single process.
Instead of using one process for each task, the main idea of the smart sensor service is to improve the efficiency of these long running tasks by using centralized processes to execute those tasks in batches.
To do that, we need to run a task in two steps, the first step is to serialize the task information into the database; and the second step is to use a few centralized processes to execute the serialized tasks in batches.
In this way, we only need a handful of running processes.
The smart sensor service is supported in a new mode called “smart sensor mode”. In smart sensor mode, instead of holding a long running process for each sensor and poking periodically, a sensor will only store poke context at sensor_instance table and then exits with a ‘sensing’ state.
When the smart sensor mode is enabled, a special set of builtin smart sensor DAGs
(named smart_sensor_group_shard_xxx) is created by the system; These DAGs contain
task and manage the smart sensor jobs for the airflow cluster. The SmartSensorOperator task can fetch
hundreds of ‘sensing’ instances from sensor_instance table and poke on behalf of them in batches.
Users don’t need to change their existing DAGs.
Enable/Disable Smart Sensor¶
Updating from a older version might need a schema change. If there is no
in the DB, please make sure to run
airflow db upgrade
Add the following settings in the
[smart_sensor] use_smart_sensor = true shard_code_upper_limit = 10000 # Users can change the following config based on their requirements shards = 5 sensors_enabled = NamedHivePartitionSensor, MetastorePartitionSensor
use_smart_sensor: This config indicates if the smart sensor is enabled.
shards: This config indicates the number of concurrently running smart sensor jobs for the airflow cluster.
sensors_enabled: This config is a list of sensor class names that will use the smart sensor. The users use the same class names (e.g. HivePartitionSensor) in their DAGs and they don’t have the control to use smart sensors or not, unless they exclude their tasks explicitly.
Enabling/disabling the smart sensor service is a system level configuration change. It is transparent to the individual users. Existing DAGs don't need to be changed for enabling/disabling the smart sensor. Rotating centralized smart sensor tasks will not cause any user’s sensor task failure.
Support new operators in the smart sensor service¶
poke_context_fieldsas class attribute in the sensor.
poke_context_fieldsinclude all key names used for initializing a sensor object.
airflow.cfg, add the new operator's classname to
[smart_sensor] sensors_enabled. All supported sensors' classname should be comma separated.