[~] Refactor
This commit is contained in:
parent
8083545b90
commit
955b7bde41
@ -21,7 +21,7 @@ app = celery.Celery(
|
|||||||
|
|
||||||
kombu_register_json_dataclass()
|
kombu_register_json_dataclass()
|
||||||
app._backend = Backend(app=app, url=c.celery_result_backend)
|
app._backend = Backend(app=app, url=c.celery_result_backend)
|
||||||
app.log.setup(loglevel=logging.INFO)
|
app.log.setup(loglevel=c.celery_log_level)
|
||||||
|
|
||||||
|
|
||||||
app.autodiscover_tasks(c.celery_imports)
|
app.autodiscover_tasks(c.celery_imports)
|
||||||
|
@ -30,6 +30,7 @@ class tiktok_config_t:
|
|||||||
celery_broker: str=''
|
celery_broker: str=''
|
||||||
celery_result_backend: str=''
|
celery_result_backend: str=''
|
||||||
celery_imports: Iterable[str]=tuple()
|
celery_imports: Iterable[str]=tuple()
|
||||||
|
celery_log_level: int=logging.INFO
|
||||||
|
|
||||||
def tiktok_config() -> tiktok_config_t.res_t:
|
def tiktok_config() -> tiktok_config_t.res_t:
|
||||||
res = tiktok_config_t.res_t(
|
res = tiktok_config_t.res_t(
|
||||||
|
Loading…
Reference in New Issue
Block a user