SIENTIAPDE-1148
refactor: remove unused prepare_activity method from Activities class and clean up worker.py activity list
This commit is contained in:
@@ -58,9 +58,5 @@ class Activities( # Couchbase,
|
|||||||
logger=logger,
|
logger=logger,
|
||||||
notification_handler=notification_handler)
|
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):
|
def shutdown(self):
|
||||||
MongoDB.shutdown(self)
|
MongoDB.shutdown(self)
|
||||||
|
|||||||
@@ -59,8 +59,6 @@ async def main():
|
|||||||
task_queue='orchestrator-queue',
|
task_queue='orchestrator-queue',
|
||||||
workflows=[Orchestrator],
|
workflows=[Orchestrator],
|
||||||
activities=[
|
activities=[
|
||||||
# Base
|
|
||||||
activities.prepare_activity,
|
|
||||||
# Redis
|
# Redis
|
||||||
activities.load_active_ingestors,
|
activities.load_active_ingestors,
|
||||||
activities.load_opc_slots,
|
activities.load_opc_slots,
|
||||||
|
|||||||
Reference in New Issue
Block a user