Move new errata record creation to dramatiq task

Author: Kwaizer

alws/dramatiq/__init__.py

@@ -34,6 +34,7 @@
 from alws.dramatiq.errata import (
     bulk_errata_release,
     bulk_new_errata_release,
+    create_new_errata,
     release_errata,
     release_new_errata,
     reset_records_threshold,

alws/dramatiq/errata.py

@@ -6,6 +6,7 @@
 from alws.crud.errata import (
     bulk_errata_records_release,
     bulk_new_errata_records_release,
+    create_new_errata_record,
     release_errata_record,
     release_new_errata_record,
     reset_matched_erratas_packages_threshold,
@@ -16,6 +17,10 @@
 __all__ = ["release_errata"]
 
 
+async def _create_new_errata(errata):
+     await create_new_errata_record(errata)
+
+
 async def _release_new_errata_record(
     record_id: str, platform_id: int, force: bool
 ):
@@ -50,6 +55,19 @@ async def _reset_matched_erratas_packages_threshold(issued_date: str):
     await reset_matched_erratas_packages_threshold(issued_date)
 
 
+@dramatiq.actor(
+    max_retries=0,
+    priority=0,
+    queue_name="errata",
+    time_limit=DRAMATIQ_TASK_TIMEOUT,
+)
+def create_new_errata(errata):
+    event_loop.run_until_complete(setup_all())
+    event_loop.run_until_complete(
+        _create_new_errata(errata)
+    )
+
+
 @dramatiq.actor(
     max_retries=0,
     priority=0,

alws/routers/errata.py

@@ -16,6 +16,7 @@
 from alws.dramatiq import (
     bulk_errata_release,
     bulk_new_errata_release,
+    create_new_errata,
     release_errata,
     release_new_errata,
     reset_records_threshold,
@@ -36,14 +37,12 @@
 
 @router.post("/new/", response_model=errata_schema.CreateErrataResponse)
 async def create_new_errata_record(
-    errata: errata_schema.BaseErrataRecord,
-    db: AsyncSession = Depends(AsyncSessionDependency(key=get_async_db_key())),
+    errata: errata_schema.BaseErrataRecord
 ):
-    record = await errata_crud.create_new_errata_record(
-        db,
-        errata,
-    )
-    return {"ok": bool(record)}
+    create_new_errata.send(errata)
+
+    message = f"Record {errata.id} is scheduled for creation"
+    return {"ok": message}
 
 
 @router.post("/", response_model=errata_schema.CreateErrataResponse)