fix celery import

Author: darjeeling

pythonkr_backend/pythonkr_backend/__init__.py

@@ -1,5 +1,9 @@
 # This will make sure the app is always imported when
 # Django starts so that shared_task will use this app.
-from .celery import app as celery_app
+from django.conf import settings
 
-__all__ = ('celery_app',)
+if settings.CELERY_ALWAYS_EAGER is False:
+    from .celery import app as celery_app
+    __all__ = ('celery_app',)
+else:
+    __all__ = ()

pythonkr_backend/pythonkr_backend/celery.py

@@ -17,12 +17,12 @@
 
 @worker_init.connect()  
 def init_worker(*args, **kwargs):
-    logfire.configure(service_name="celery-worker")  
+    logfire.configure(service_name="celery-worker", send_to_logfire='if-token-present')  
     logfire.instrument_celery()
 
 @beat_init.connect()  
 def init_beat(*args, **kwargs):
-    logfire.configure(service_name="celery-beat")  
+    logfire.configure(service_name="celery-beat", send_to_logfire='if-token-present')  
     logfire.instrument_celery()
 
 @app.task

pythonkr_backend/pythonkr_backend/settings/base.py

@@ -187,23 +187,10 @@
     "0.0.0.0",
 ]
 
-# LOGGING
-
-LOGGING = {
-    "version": 1,
-    "disable_existing_loggers": False,
-    "handlers": {
-        "console": {
-            "class": "logging.StreamHandler",
-        },
-    },
-    "root": {
-        "handlers": ["console"],
-        "level": "INFO",
-    },
-}
-
 # import logfire
 # setup logfire
 #logfire.configure(environment='base', service_name="web")
-#logfire.instrument_django()
+#logfire.instrument_django()
+
+# testing
+CELERY_ALWAYS_EAGER = True

pythonkr_backend/pythonkr_backend/settings/localtesting.py

@@ -29,7 +29,15 @@
 BAKERY_MULTISITE = True
 BUILD_DIR = os.path.join("/app/bakery_static", "build")
 
+
+# check WSGI environment
+IS_PRODUCTION_SERVER = os.environ.get('IS_WSGI_ENVIRONMENT', 'False') == 'True'
+
+
 # logfire settings
 if IS_PRODUCTION_SERVER:
     logfire.configure(environment='localtest')
-    logfire.instrument_django()
+    logfire.instrument_django()
+
+# testing
+CELERY_ALWAYS_EAGER = True

pythonkr_backend/pythonkr_backend/settings/prod.py

@@ -73,7 +73,8 @@
 CELERY_BROKER_USERNAME = os.environ.get("CELERY_USERNAME","FALSE")
 CELERY_BROKER_VHOST = os.environ.get("CELERY_VHOST","FALSE")
 # Celery Configuration Options
+CELERY_ALWAYS_EAGER = False
 CELERY_TIMEZONE = "Asia/Seoul"
 CELERY_TASK_TRACK_STARTED = True
-CELERY_BROKER_URL = "amqp://userid:password@localhost:port/virtual_host"
+CELERY_BROKER_URL = f"amqp://{CELERY_BROKER_USERNAME}:{CELERY_BROKER_PASSWORD}@localhost:5672/{CELERY_BROKER_VHOST}"
 CELERY_TASK_TIME_LIMIT = 30 * 60