bhirsz commented on code in PR #26606:
URL: https://github.com/apache/airflow/pull/26606#discussion_r981022667
##########
tests/system/providers/amazon/aws/example_s3.py:
##########
@@ -202,6 +203,12 @@ def check_fn(files: list) -> bool:
)
# [END howto_operator_s3_file_transform]
+ # This task skips the `sensor_keys_unchanged` task because the
S3KeysUnchangedSensor
Review Comment:
We overwrite the ``poke`` mode for the sensors (but not for all, I need to
investigate the results..):
```
# [START howto_sensor_object_exists_task]
gcs_object_exists = GCSObjectExistenceSensor(
bucket=BUCKET_NAME,
object=FILE_NAME,
mode='poke',
task_id="gcs_object_exists_task",
)
# [END howto_sensor_object_exists_task]
```
Other option is to design the tests in a way, that if sensor is in
reschedule mode it will not fail on first try (ie. if you're waiting for some
file to appear, to upload the file first then run the sensor).
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
