celery working

app/__init__.py

@@ -1,4 +1,5 @@
-# from celery import Celery, Task
+# import logging as log
+
 from celery import Celery, Task
 from flask import Flask
 from flask_assets import Environment
@@ -86,3 +87,33 @@ def __call__(self, *args: object, **kwargs: object) -> object:
 
 
 celery_app = celery_init_app(app)
+
+# log.basicConfig(level=log.INFO, format='%(asctime)s - %(name)s - %(levelname)s - %(message)s')
+# logger = log.getLogger(__name__)
+
+
+# log.basicConfig(level=log.INFO,
+#                     format='%(asctime)s - %(name)s - %(levelname)s - %(message)s',
+#                     handlers=[
+#                         log.FileHandler("celery_log.txt"),
+#                         log.StreamHandler()
+#                     ])
+
+# logger = log.getLogger(__name__)
+
+
+# logger = log.getLogger(__name__)
+# logger.setLevel(log.INFO)
+
+# file_handler = log.FileHandler('celery_log.txt')
+# file_handler.setLevel(log.INFO)
+
+# console_handler = log.StreamHandler()
+# console_handler.setLevel(log.INFO)
+
+# formatter = log.Formatter('%(asctime)s - %(name)s - %(levelname)s - %(message)s')
+# file_handler.setFormatter(formatter)
+# console_handler.setFormatter(formatter)
+
+# logger.addHandler(file_handler)
+# logger.addHandler(console_handler)

tasks.py

@@ -1,3 +1,4 @@
+from time import sleep
 from urllib.parse import urlencode
 
 import requests
@@ -8,6 +9,10 @@
 
 @shared_task(ignore_result=False)
 def process_async_download(query_params: dict):
+    for i in range(10):
+        print(f"Processing async download {i}")
+        sleep(1)
+
     request_url = (
         Config.DATA_STORE_API_HOST
         + "/async_download"