File tree Expand file tree Collapse file tree 2 files changed +6
-5
lines changed
src/apify_client/clients/resource_clients Expand file tree Collapse file tree 2 files changed +6
-5
lines changed Original file line number Diff line number Diff line change @@ -747,10 +747,10 @@ async def call(
747
747
if logger == 'default' :
748
748
logger = None
749
749
750
- async with (
751
- await run_client .get_status_message_redirector (to_logger = logger ),
752
- await run_client . get_streamed_log ( to_logger = logger ),
753
- ) :
750
+ status_redirector = await run_client . get_status_message_redirector ( to_logger = logger )
751
+ streamed_log = await run_client .get_streamed_log (to_logger = logger )
752
+
753
+ async with status_redirector , streamed_log :
754
754
return await self .root_client .run (started_run ['id' ]).wait_for_finish (wait_secs = wait_secs )
755
755
756
756
async def build (
Original file line number Diff line number Diff line change @@ -477,7 +477,8 @@ async def __aexit__(
477
477
478
478
async def _log_changed_status_message (self ) -> None :
479
479
while True :
480
- if not self ._log_run_data (await self ._run_client .get ()):
480
+ run_data = await self ._run_client .get ()
481
+ if not self ._log_run_data (run_data ):
481
482
break
482
483
await asyncio .sleep (self ._check_period )
483
484
You can’t perform that action at this time.
0 commit comments