diff --git a/orchestrator/activities/activities.py b/orchestrator/activities/activities.py index 97851cb..02437c2 100644 --- a/orchestrator/activities/activities.py +++ b/orchestrator/activities/activities.py @@ -58,9 +58,5 @@ class Activities( # Couchbase, logger=logger, notification_handler=notification_handler) - @activity.defn(name="prepare_activity") - async def prepare_activity(self, input_data: dict[str, Any]): - await super().prepare_activity(input_data) - def shutdown(self): MongoDB.shutdown(self) diff --git a/orchestrator/worker/worker.py b/orchestrator/worker/worker.py index f4a2804..76c88f1 100644 --- a/orchestrator/worker/worker.py +++ b/orchestrator/worker/worker.py @@ -59,8 +59,6 @@ async def main(): task_queue='orchestrator-queue', workflows=[Orchestrator], activities=[ - # Base - activities.prepare_activity, # Redis activities.load_active_ingestors, activities.load_opc_slots,