feat: add execute_update_node to worker activity registration

main
Cizz22 3 months ago
parent 57593f6a28
commit bad7b53337

@ -3,7 +3,7 @@ import os
from temporalio.client import Client from temporalio.client import Client
from temporalio.worker import Worker from temporalio.worker import Worker
from temporal.activity import calculate_plant_eaf_activity, execute_simulation_activity, update_contribution_bulk_mappings_activity, update_equipment_for_simulation_activity, call_callback_ahm, acquire_lock, release_lock from temporal.activity import calculate_plant_eaf_activity, execute_simulation_activity, update_contribution_bulk_mappings_activity, update_equipment_for_simulation_activity, call_callback_ahm, acquire_lock, release_lock,execute_update_node
from temporal.workflow import SimulationWorkflow from temporal.workflow import SimulationWorkflow
TEMPORAL_URL = os.environ.get("TEMPORAL_URL", "http://192.168.1.86:7233") TEMPORAL_URL = os.environ.get("TEMPORAL_URL", "http://192.168.1.86:7233")
@ -23,7 +23,8 @@ async def main():
update_contribution_bulk_mappings_activity, update_contribution_bulk_mappings_activity,
call_callback_ahm, call_callback_ahm,
acquire_lock, acquire_lock,
release_lock release_lock,
execute_update_node
], ],
max_concurrent_workflow_tasks=50, max_concurrent_workflow_tasks=50,
max_concurrent_activities=12 max_concurrent_activities=12

Loading…
Cancel
Save