dabla commented on PR #38715:
URL: https://github.com/apache/airflow/pull/38715#issuecomment-2050338045
Also wondering why these tests are failing as those are unrelated with my
changes (I think):
```
_______________ TestWasbBlobSensorTrigger.test_waiting_for_blob
________________
[gw1] linux -- Python 3.8.19 /usr/local/bin/python
self =
<tests.providers.microsoft.azure.triggers.test_wasb.TestWasbBlobSensorTrigger
object at 0x7f2742e336d0>
mock_check_for_blob = <AsyncMock name='check_for_blob_async'
id='139805898015072'>
caplog = <_pytest.logging.LogCaptureFixture object at 0x7f2718e380a0>
@pytest.mark.asyncio
@mock.patch("airflow.providers.microsoft.azure.hooks.wasb.WasbAsyncHook.check_for_blob_async")
async def test_waiting_for_blob(self, mock_check_for_blob, caplog):
"""Tests the WasbBlobSensorTrigger sleeps waiting for the blob to
arrive."""
mock_check_for_blob.side_effect = [False, True]
caplog.set_level(logging.INFO)
with mock.patch.object(self.TRIGGER.log, "info"):
task = asyncio.create_task(self.TRIGGER.run().__anext__())
await asyncio.sleep(POKE_INTERVAL + 0.5)
if not task.done():
message = (
f"Blob {TEST_DATA_STORAGE_BLOB_NAME} not available yet in
container {TEST_DATA_STORAGE_CONTAINER_NAME}."
f" Sleeping for {POKE_INTERVAL} seconds"
)
> assert message in caplog.text
E assert 'Blob test_blob_providers_team.txt not available yet in
container test-container-providers-team. Sleeping for 5.0 seconds' in "WARNING
airflow.api_internal.internal_api_call:before.py:40 Starting call to
'airflow.api_internal.internal_api_call...ow.api_internal.internal_api_call.internal_api_call.<locals>.make_jsonrpc_request',
this is the 3rd time calling it.\n"
E + where "WARNING
airflow.api_internal.internal_api_call:before.py:40 Starting call to
'airflow.api_internal.internal_api_call...ow.api_internal.internal_api_call.internal_api_call.<locals>.make_jsonrpc_request',
this is the 3rd time calling it.\n" = <_pytest.logging.LogCaptureFixture
object at 0x7f2718e380a0>.text
tests/providers/microsoft/azure/triggers/test_wasb.py:115: AssertionError
```
--
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]
