diff --git a/orchestrator/activities/temporal_manager.py b/orchestrator/activities/temporal_manager.py index 73d81d3..e78b46e 100644 --- a/orchestrator/activities/temporal_manager.py +++ b/orchestrator/activities/temporal_manager.py @@ -1,5 +1,3 @@ -from asyncio import sleep -from http import client from temporalio import activity, workflow from temporalio.client import ( Client, Schedule, ScheduleActionStartWorkflow, ScheduleIntervalSpec, ScheduleSpec, ScheduleUpdate, ScheduleUpdateInput) @@ -14,6 +12,7 @@ with workflow.unsafe.imports_passed_through(): import base64 from datetime import timedelta import json + from asyncio import sleep from orchestrator.utils.converters import parse_frequency @@ -41,6 +40,11 @@ class TemporalManager(BaseActivity): notification_handler=notification_handler) async def connect_to_temporal(self): + self.logger.info("Connecting to Temporal side namespaces...") + + self.logger.info(f"Scouter namespace: {self.scouter_namespace}") + self.logger.info(f"Laborious namespace: {self.laborious_namespace}") + self.temporal_clients = { self.scouter_namespace: await Client.connect( target_host=self.host,