@@ -579,7 +579,7 @@ async def test_batch_with_label_async(async_client: AsyncQStash) -> None:
579579 # Verify the messages have the correct labels
580580 message1 = await async_client .message .get (result [0 ].message_id )
581581 message2 = await async_client .message .get (result [1 ].message_id )
582-
582+
583583 assert message1 .label == "async-batch-label-1"
584584 assert message2 .label == "async-batch-label-2"
585585
@@ -608,7 +608,7 @@ async def test_batch_json_with_label_async(async_client: AsyncQStash) -> None:
608608 # Verify the messages have the correct labels
609609 message1 = await async_client .message .get (result [0 ].message_id )
610610 message2 = await async_client .message .get (result [1 ].message_id )
611-
611+
612612 assert message1 .label == "async-batch-json-label-1"
613613 assert message2 .label == "async-batch-json-label-2"
614614
@@ -623,15 +623,17 @@ async def test_log_filtering_by_label_async(async_client: AsyncQStash) -> None:
623623 )
624624
625625 assert isinstance (res , PublishResponse )
626-
626+
627627 # Wait for message delivery and then check logs with label filter
628628 async def assertion () -> None :
629- logs = (await async_client .log .list (
630- filter = {
631- "label" : "async-log-filter-test" ,
632- }
633- )).logs
634-
629+ logs = (
630+ await async_client .log .list (
631+ filter = {
632+ "label" : "async-log-filter-test" ,
633+ }
634+ )
635+ ).logs
636+
635637 # Should find at least one log entry with our label
636638 assert len (logs ) > 0
637639 # Verify that all returned logs have the expected label
0 commit comments