Commit fa4fb118 authored by Qarnot computing's avatar Qarnot computing

Synchronous eo plan hanlding

parent 4d4d302d
...@@ -62,7 +62,8 @@ class ITLBClientDaemon: ...@@ -62,7 +62,8 @@ class ITLBClientDaemon:
# Handling an EO plan may be relatively long (querying the DB API, then the # Handling an EO plan may be relatively long (querying the DB API, then the
# SLARC, then talking to the DCMC), so let's execute it concurrently. Most of # SLARC, then talking to the DCMC), so let's execute it concurrently. Most of
# the wait time will be IO so just spawning a task should be enough. # the wait time will be IO so just spawning a task should be enough.
asyncio.create_task(self._handle_optimisation_plan(msg)) # asyncio.create_task(self._handle_optimisation_plan(msg))
await self._handle_optimisation_plan(msg)
elif isinstance(msg, list) and isinstance(msg[0], MigrationStatus): elif isinstance(msg, list) and isinstance(msg[0], MigrationStatus):
log.info("Got migration statuses: %s", msg) log.info("Got migration statuses: %s", msg)
await self._handle_migration_status(msg) await self._handle_migration_status(msg)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment