diff --git a/scouter/workflow/sub_workflows/core_scouter.py b/scouter/workflow/sub_workflows/core_scouter.py index 3beb4d9..89bf7ff 100644 --- a/scouter/workflow/sub_workflows/core_scouter.py +++ b/scouter/workflow/sub_workflows/core_scouter.py @@ -5,7 +5,7 @@ with workflow.unsafe.imports_passed_through(): from typing import Any from datetime import timedelta from sientia_do.temporal.policies import retry_policy - from sientia_do.temporal.constants import DATETIME_FORMAT_MS_WITH_TZ + from sientia_do.temporal.constants import DATETIME_FORMAT_WITH_TZ @workflow.defn(name="core_scouter") @@ -85,7 +85,7 @@ class CoreScouter: 'data': held_data, 'timestamp_conversion': { 'column': 'timestamp', - 'format': DATETIME_FORMAT_MS_WITH_TZ + 'format': DATETIME_FORMAT_WITH_TZ } }, retry_policy=retry_policy,