Fix cyclic import with a new file

alws/dramatiq/__init__.py

@@ -8,12 +8,10 @@
        and it's important for all tasks which involves user interaction
        to have priority 0.
     4. If you need to use async function in your dramatiq task - ALWAYS use
-       loop from this __init__.py, since creating multiple loops for tasks
+       loop from this _event_loop.py, since creating multiple loops for tasks
        will break your tasks.
 """
 
-import asyncio
-
 import dramatiq
 from dramatiq.brokers.rabbitmq import RabbitmqBroker
 
@@ -27,7 +25,6 @@
     f"{settings.rabbitmq_default_vhost}",
 )
 dramatiq.set_broker(rabbitmq_broker)
-event_loop = asyncio.get_event_loop()
 
 # Tasks import started from here
 from alws.dramatiq.build import build_done, start_build

alws/dramatiq/_event_loop.py

@@ -0,0 +1,3 @@
+import asyncio
+
+event_loop = asyncio.get_event_loop()

alws/dramatiq/build.py

@@ -21,7 +21,7 @@
 from alws.crud import build_node as build_node_crud
 from alws.crud import test
 from alws.dependencies import get_async_db_key
-from alws.dramatiq import event_loop
+from alws.dramatiq._event_loop import event_loop
 from alws.errors import (
     ArtifactConversionError,
     ModuleUpdateError,

alws/dramatiq/errata.py

@@ -10,7 +10,7 @@
     release_new_errata_record,
     reset_matched_erratas_packages_threshold,
 )
-from alws.dramatiq import event_loop
+from alws.dramatiq._event_loop import event_loop
 from alws.utils.fastapi_sqla_setup import setup_all
 
 __all__ = ["release_errata"]

alws/dramatiq/products.py

@@ -13,7 +13,7 @@
 from alws.config import settings
 from alws.constants import DRAMATIQ_TASK_TIMEOUT, BuildTaskStatus
 from alws.dependencies import get_async_db_key
-from alws.dramatiq import event_loop
+from alws.dramatiq._event_loop import event_loop
 from alws.utils.fastapi_sqla_setup import setup_all
 from alws.utils.log_utils import setup_logger
 from alws.utils.pulp_client import PulpClient

alws/dramatiq/releases.py

@@ -1,12 +1,10 @@
-from contextlib import asynccontextmanager
-
 import dramatiq
 from fastapi_sqla import open_async_session
 
 from alws.constants import DRAMATIQ_TASK_TIMEOUT
 from alws.crud import release as r_crud
 from alws.dependencies import get_async_db_key
-from alws.dramatiq import event_loop
+from alws.dramatiq._event_loop import event_loop
 from alws.utils.fastapi_sqla_setup import setup_all
 
 __all__ = ["execute_release_plan"]

alws/dramatiq/sign_task.py

@@ -4,7 +4,7 @@
 
 from alws.constants import DRAMATIQ_TASK_TIMEOUT
 from alws.crud import sign_task
-from alws.dramatiq import event_loop
+from alws.dramatiq._event_loop import event_loop
 from alws.schemas import sign_schema
 from alws.utils.fastapi_sqla_setup import setup_all
 

alws/dramatiq/tests.py

@@ -7,7 +7,7 @@
 from alws.constants import DRAMATIQ_TASK_TIMEOUT, TestTaskStatus
 from alws.crud import test as t_crud
 from alws.dependencies import get_async_db_key
-from alws.dramatiq import event_loop
+from alws.dramatiq._event_loop import event_loop
 from alws.schemas.test_schema import TestTaskResult
 from alws.utils.fastapi_sqla_setup import setup_all
 

alws/dramatiq/user.py

@@ -7,7 +7,7 @@
 from alws.constants import DRAMATIQ_TASK_TIMEOUT
 from alws.crud import build as build_crud
 from alws.dependencies import get_async_db_key
-from alws.dramatiq import event_loop
+from alws.dramatiq._event_loop import event_loop
 from alws.utils.fastapi_sqla_setup import setup_all
 
 __all__ = ['perform_user_removal']