feat: entity tasks were created

src/recommendation_engine/app/tasks/__init__.py

@@ -1 +1,4 @@
+from .menu import *
+from .comments import *
+from .restaurant import *
 from .data_extraction import *

src/recommendation_engine/app/tasks/comments.py

@@ -0,0 +1,13 @@
+from celery.app.task import Task
+
+from ..shared_kernel.scheduler.celery_app import celery_application
+
+
+class CommentTask(Task):
+    __name__ = "CommentTask"
+
+    def run(self, *args, **kwargs):
+        pass
+
+
+celery_application.register_task(CommentTask)

src/recommendation_engine/app/tasks/data_extraction.py

@@ -1,3 +1,4 @@
+import celery
 from celery.app.task import Task
 from celery.schedules import crontab
 
@@ -8,7 +9,15 @@ class DataExtractionTask(Task):
     __name__ = "DataExtractionTask"
 
     def run(self, *args, **kwargs):
-        pass
+        from .menu import MenuTask
+        from .comments import CommentTask
+        from .restaurant import RestaurantTask
+
+        menu_task = MenuTask()
+        comment_task = CommentTask()
+        restaurant_task = RestaurantTask()
+
+        celery.chain(restaurant_task.s(), menu_task.s(), comment_task.s()).apply_async()
 
 
 celery_application.register_task(DataExtractionTask)

src/recommendation_engine/app/tasks/menu.py

@@ -0,0 +1,13 @@
+from celery.app.task import Task
+
+from ..shared_kernel.scheduler.celery_app import celery_application
+
+
+class MenuTask(Task):
+    __name__ = "MenuTask"
+
+    def run(self, *args, **kwargs):
+        pass
+
+
+celery_application.register_task(MenuTask)

src/recommendation_engine/app/tasks/restaurant.py

@@ -0,0 +1,13 @@
+from celery.app.task import Task
+
+from ..shared_kernel.scheduler.celery_app import celery_application
+
+
+class RestaurantTask(Task):
+    __name__ = "RestaurantTask"
+
+    def run(self, *args, **kwargs):
+        pass
+
+
+celery_application.register_task(RestaurantTask)