Wait for Hasura to be configured before starting indexing (#251)

Author: droserasprout

CHANGELOG.md

@@ -7,6 +7,7 @@ Please use [this](https://docs.gitlab.com/ee/development/changelog.html) documen
 ### Fixed
 
 * database: Do not add the `schema` argument to the PostgreSQL connection string when not needed.
+* hasura: Wait for Hasura to be configured before starting indexing.
 
 ## 4.2.4 - 2022-02-14
 

src/dipdup/dipdup.py

@@ -352,7 +352,7 @@ async def run(self) -> None:
 
             await self._initialize_schema()
             await self._initialize_datasources()
-            await self._set_up_hasura(stack, tasks)
+            await self._set_up_hasura(stack)
 
             if self._config.oneshot:
                 start_scheduler_event, spawn_datasources_event = Event(), Event()
@@ -481,15 +481,15 @@ async def _set_up_hooks(self, tasks: Optional[Set[Task]] = None) -> None:
         if tasks:
             tasks.add(create_task(self._ctx.callbacks.run()))
 
-    async def _set_up_hasura(self, stack: AsyncExitStack, tasks: Set[Task]) -> None:
+    async def _set_up_hasura(self, stack: AsyncExitStack) -> None:
         if not self._config.hasura:
             return
 
         if not isinstance(self._config.database, PostgresDatabaseConfig):
             raise RuntimeError
         hasura_gateway = HasuraGateway(self._config.package, self._config.hasura, self._config.database)
         await stack.enter_async_context(hasura_gateway)
-        tasks.add(create_task(hasura_gateway.configure()))
+        await hasura_gateway.configure()
 
     async def _set_up_datasources(self, stack: AsyncExitStack) -> None:
         await self._create_datasources()