add a global async scheduler (#4117)

src/fides/api/main.py

@@ -32,7 +32,7 @@
 from fides.api.service.privacy_request.email_batch_service import (
     initiate_scheduled_batch_email_send,
 )
-from fides.api.tasks.scheduled.scheduler import scheduler
+from fides.api.tasks.scheduled.scheduler import async_scheduler, scheduler
 from fides.api.ui import (
     get_admin_index_as_response,
     get_path_to_admin_ui_file,
@@ -262,6 +262,8 @@ async def setup_server() -> None:
 
     if not scheduler.running:
         scheduler.start()
+    if not async_scheduler.running:
+        async_scheduler.start()
 
     initiate_scheduled_batch_email_send()
 

src/fides/api/tasks/scheduled/scheduler.py

@@ -1,3 +1,5 @@
+from apscheduler.schedulers.asyncio import AsyncIOScheduler
 from apscheduler.schedulers.background import BackgroundScheduler
 
 scheduler = BackgroundScheduler()
+async_scheduler = AsyncIOScheduler()

tests/ops/conftest.py

@@ -11,7 +11,7 @@
 from fides.api.db.base import Base
 from fides.api.db.session import get_db_engine, get_db_session
 from fides.api.models.sql_models import DataCategory as DataCategoryDbModel
-from fides.api.tasks.scheduled.scheduler import scheduler
+from fides.api.tasks.scheduled.scheduler import async_scheduler, scheduler
 from tests.conftest import create_citext_extension
 
 
@@ -37,6 +37,9 @@ def db(api_client, config):
 
     if not scheduler.running:
         scheduler.start()
+    if not async_scheduler.running:
+        async_scheduler.start()
+
     SessionLocal = get_db_session(config, engine=engine)
     the_session = SessionLocal()
     # Setup above...