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(
747747 if logger == 'default' :
748748 logger = None
749749
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 :
754754 return await self .root_client .run (started_run ['id' ]).wait_for_finish (wait_secs = wait_secs )
755755
756756 async def build (
Original file line number Diff line number Diff line change @@ -477,7 +477,8 @@ async def __aexit__(
477477
478478 async def _log_changed_status_message (self ) -> None :
479479 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 ):
481482 break
482483 await asyncio .sleep (self ._check_period )
483484
You can’t perform that action at this time.
0 commit comments