explicit connect made mandatory

chatsky/context_storages/database.py

@@ -95,7 +95,7 @@ def _lock(function: Callable[..., Awaitable[Any]]):
     @wraps(function)
     async def wrapped(self: DBContextStorage, *args, **kwargs):
         if not self.connected:
-            await self.connect()
+            raise RuntimeError("ContextStorage has to be connected before it can be used!")
         if not self.is_concurrent:
             async with self._sync_lock:
                 return await function(self, *args, **kwargs)

chatsky/core/pipeline.py

@@ -291,4 +291,6 @@ def __call__(
 
         This method has the same signature as :py:class:`~chatsky.core.service.types.PipelineRunnerFunction`.
         """
+        if not self.context_storage.connected:
+            asyncio.run(self.context_storage.connect())
         return asyncio.run(self._run_pipeline(request, ctx_id, update_ctx_misc))

tests/context_storages/test_dbs.py

@@ -158,6 +158,7 @@ async def db(self, db_kwargs, db_teardown, tmpdir_factory):
             kwargs["__testing_file__"] = str(tmpdir_factory.mktemp("data").join("file.db"))
         db_kwargs["path"] = db_kwargs["path"].format(**kwargs)
         context_storage = context_storage_factory(**db_kwargs)
+        await context_storage.connect()
 
         yield context_storage