Skip to content

Commit 4e28740

Browse files
committed
Review fix
Signed-off-by: cyc60 <[email protected]>
1 parent a5a5d12 commit 4e28740

File tree

1 file changed

+16
-12
lines changed

1 file changed

+16
-12
lines changed

src/commands/start.py

+16-12
Original file line numberDiff line numberDiff line change
@@ -294,19 +294,23 @@ async def main() -> None:
294294
logger.info('Started operator service')
295295
with InterruptHandler() as interrupt_handler:
296296
while not interrupt_handler.exit:
297-
await ValidatorsTask(
298-
keystores=keystores,
299-
remote_signer_config=remote_signer_config,
300-
deposit_data=deposit_data,
301-
).run()
302-
await ExitSignatureTask(
303-
keystores=keystores,
304-
remote_signer_config=remote_signer_config,
305-
).run()
297+
tasks = [
298+
ValidatorsTask(
299+
keystores=keystores,
300+
remote_signer_config=remote_signer_config,
301+
deposit_data=deposit_data,
302+
).run(),
303+
ExitSignatureTask(
304+
keystores=keystores,
305+
remote_signer_config=remote_signer_config,
306+
).run(),
307+
MetricsTask().run(),
308+
WalletTask().run(),
309+
]
306310
if settings.harvest_vault:
307-
await HarvestTask().run()
308-
await MetricsTask().run()
309-
await WalletTask().run()
311+
tasks.append(HarvestTask().run())
312+
313+
await asyncio.gather(*tasks)
310314

311315

312316
def log_start() -> None:

0 commit comments

Comments
 (0)