tests.system.google.cloud.gcs.example_gcs_sensor¶
Example Airflow DAG for Google Cloud Storage sensors.
Attributes¶
Functions¶
DebugExecutor change sensor mode from poke to reschedule. Some sensors don't work correctly |
|
Module Contents¶
- tests.system.google.cloud.gcs.example_gcs_sensor.RESOURCES_BUCKET_NAME = 'airflow-system-tests-resources'[source]¶
- tests.system.google.cloud.gcs.example_gcs_sensor.DESTINATION_BUCKET_NAME = 'bucket_gcs_sensor_Uninferable'[source]¶
- tests.system.google.cloud.gcs.example_gcs_sensor.UPLOAD_FILE_PATH = 'gcs/example_upload.txt'[source]¶
- tests.system.google.cloud.gcs.example_gcs_sensor.workaround_in_debug_executor(cls)[source]¶
DebugExecutor change sensor mode from poke to reschedule. Some sensors don’t work correctly in reschedule mode. They are decorated with poke_mode_only decorator to fail when mode is changed. This method creates dummy property to overwrite it and force poke method to always return True.