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

SIENTIAPDE-1184

Browse Source 
Changing "updated_at" type from str to datetime
This commit is contained in:
vitor-aignosi
2025-08-13 16:34:02 -03:00
parent 1306bed21d
commit 4d75d581f8
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
orchestrator/activities/formatters.py
View File

@@ -198,7 +198,7 @@ class Formatters(BaseActivity):
if schedule_name in current_schedules: if schedule_name in current_schedules:
update_timestamp = schedule.get( update_timestamp = schedule.get(
'updated_at', datetime.now().strftime(DEFAULT_DATE_FORMAT)) 'updated_at', datetime.now())
old_timestamp = current_schedules[schedule_name] old_timestamp = current_schedules[schedule_name]

4
orchestrator/activities/mongo_db.py
View File

@@ -206,7 +206,7 @@ class MongoDB(BaseActivity):
""" """
updated_pipelines = input_data.get("updated_pipelines", []) updated_pipelines = input_data.get("updated_pipelines", [])
metadata = input_data.get("metadata", {}) metadata = input_data.get("metadata", {})
now = datetime.now().strftime(DEFAULT_DATE_FORMAT) now = datetime.now()
collection = self.database["orchestrated_schedules"] collection = self.database["orchestrated_schedules"]
argument = [ argument = [
@@ -245,7 +245,7 @@ class MongoDB(BaseActivity):
metadata = input_data.get("metadata", {}) metadata = input_data.get("metadata", {})
collection = self.database["orchestrated_schedules"] collection = self.database["orchestrated_schedules"]
now = datetime.now().strftime(DEFAULT_DATE_FORMAT) now = datetime.now()
argument = [ argument = [
{"schedule_name": pipeline["schedule_name"], {"schedule_name": pipeline["schedule_name"],