gitea_admin/sientia-dataops-orchestrator_temporal
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

SIENTIAPDE-1148

Browse Source 
feat: add logging for Temporal namespace connection in temporal_manager.py
This commit is contained in:
vitor-aignosi
2025-07-11 10:39:08 -03:00
parent 71f0db1c60
commit 96af810755
1 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
orchestrator/activities/temporal_manager.py
View File

@@ -1,5 +1,3 @@
from asyncio import sleep
from http import client
from temporalio import activity, workflow from temporalio import activity, workflow
from temporalio.client import ( from temporalio.client import (
Client, Schedule, ScheduleActionStartWorkflow, ScheduleIntervalSpec, ScheduleSpec, ScheduleUpdate, ScheduleUpdateInput) Client, Schedule, ScheduleActionStartWorkflow, ScheduleIntervalSpec, ScheduleSpec, ScheduleUpdate, ScheduleUpdateInput)
@@ -14,6 +12,7 @@ with workflow.unsafe.imports_passed_through():
import base64 import base64
from datetime import timedelta from datetime import timedelta
import json import json
from asyncio import sleep
from orchestrator.utils.converters import parse_frequency from orchestrator.utils.converters import parse_frequency
@@ -41,6 +40,11 @@ class TemporalManager(BaseActivity):
notification_handler=notification_handler) notification_handler=notification_handler)
async def connect_to_temporal(self): 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.temporal_clients = {
self.scouter_namespace: await Client.connect( self.scouter_namespace: await Client.connect(
target_host=self.host, target_host=self.host,