6
6
"""
7
7
8
8
import atexit
9
- import os
9
+ import logging
10
10
import subprocess
11
11
import typing as t
12
12
20
20
class CeleryServer (BaseServer , Celery ):
21
21
"""A server for a Celery app."""
22
22
23
- def __init__ (
24
- self ,
25
- auto_run : bool = True ,
26
- debug : bool = bool (int (os .getenv ("DEBUG" , "1" ))),
27
- ):
23
+ def __init__ (self , auto_run : bool = True ):
28
24
"""Initialize a Celery app.
29
25
30
26
Examples:
@@ -39,7 +35,6 @@ def __init__(
39
35
40
36
Args:
41
37
auto_run: A flag designating whether to auto-run the server.
42
- debug: A flag designating whether to run the app in debug mode.
43
38
44
39
Raises:
45
40
EnvironmentError: If "DJANGO_SETTINGS_MODULE" is not in os.environ.
@@ -63,17 +58,17 @@ def __init__(
63
58
# Load task modules from all registered Django apps.
64
59
self .autodiscover_tasks ()
65
60
66
- if debug :
61
+ if self . django_dev_server_is_running () :
67
62
68
63
@self .task (
69
- name = f"{ settings .SERVICE_NAME } .debug " ,
64
+ name = f"{ settings .SERVICE_NAME } .dump_request " ,
70
65
bind = True ,
71
66
ignore_result = True ,
72
67
)
73
- def _debug (self , * args , ** kwargs ):
68
+ def dump_request (self , * args , ** kwargs ):
74
69
"""Dumps its own request information."""
75
70
76
- print ( f "Request: { self .request !r } " )
71
+ logging . info ( "Request: %s" , self .request )
77
72
78
73
if auto_run and (
79
74
self .app_server_is_running () or self .django_dev_server_is_running ()
0 commit comments