Skip to content
Snippets Groups Projects

Added celery worker and celery beat

Merged Mohammad Torkashvand requested to merge feature/NAT-358-setup-celery into develop
All threads resolved!
Files
2
+ 3
6
import typer
import typer
from orchestrator import OrchestratorCore
from orchestrator import OrchestratorCore, app_settings
from orchestrator.cli.main import app as cli_app
from orchestrator.cli.main import app as cli_app
from orchestrator.settings import AppSettings
import gso.products # noqa: F401
import gso.products # noqa: F401
import gso.workflows # noqa: F401
import gso.workflows # noqa: F401
from gso.api import router as api_router
from gso.api import router as api_router
from gso.cli import netbox
from gso.cli import netbox
base_settings = AppSettings() # TODO check if this is correct
def init_gso_app() -> OrchestratorCore:
def init_gso_app() -> OrchestratorCore:
app = OrchestratorCore(base_settings=base_settings)
app = OrchestratorCore(base_settings=app_settings)
app.include_router(api_router, prefix="/api")
app.include_router(api_router, prefix="/api")
return app
return app
def init_worker_app() -> OrchestratorCore:
def init_worker_app() -> OrchestratorCore:
return OrchestratorCore(base_settings=base_settings)
return OrchestratorCore(base_settings=app_settings)
def init_cli_app() -> typer.Typer:
def init_cli_app() -> typer.Typer:
Loading