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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
