pankajastro commented on PR #34919: URL: https://github.com/apache/airflow/pull/34919#issuecomment-1846993082
Hey @atrbgithub looks like `GCSObjectsWithPrefixExistenceSensor` is broken after this PR change I just did a quick run and got the below error. **Sensor** ``` gcs_object_with_prefix_exists = GCSObjectsWithPrefixExistenceSensor( bucket=BUCKET_1, prefix=PATH_TO_UPLOAD_FILE_PREFIX, task_id="gcs_object_with_prefix_exists_task", google_cloud_conn_id=GCP_CONN_ID, ) ``` **Error** ``` [2023-12-08, 09:48:24 UTC] {taskinstance.py:1937} ERROR - Task failed with exception Traceback (most recent call last): File "/usr/local/lib/python3.9/site-packages/airflow/providers/google/cloud/sensors/gcs.py", line 338, in execute super().execute(context) File "/usr/local/lib/python3.9/site-packages/airflow/sensors/base.py", line 257, in execute raise e File "/usr/local/lib/python3.9/site-packages/airflow/sensors/base.py", line 239, in execute poke_return = self.poke(context) File "/usr/local/lib/python3.9/site-packages/airflow/providers/google/cloud/sensors/gcs.py", line 331, in poke self._matches = hook.list(self.bucket, prefix=self.prefix) File "/usr/local/lib/python3.9/site-packages/airflow/providers/google/cloud/hooks/gcs.py", line 763, in list self._list( File "/usr/local/lib/python3.9/site-packages/airflow/providers/google/cloud/hooks/gcs.py", line 829, in _list ids.extend(blob.name for blob in blobs) File "/usr/local/lib/python3.9/site-packages/google/api_core/page_iterator.py", line 223, in __iter__ raise ValueError("Iterator has already started", self) ValueError: ('Iterator has already started', <google.api_core.page_iterator.HTTPIterator object at 0x7efe067c3880>) ``` -- 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: commits-unsubscr...@airflow.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org