SIENTIAPDE-1005

Fix

input_sample.json

@@ -1,7 +1,7 @@
 {
-    "topic": "fake_data",
+    "topic": "opcua",
-    "schedule_name": "scouter-fake-pipeline",
+    "schedule_name": "scouter-opcua-pipeline",
-    "model_name": "fake_model",
+    "model_name": "Demo Model",
     "model_id": 1,
     "trigger_laborious": false,
     "filters": {
@@ -12,31 +12,19 @@
             "policy": "DISCARD"
         }
     },
-    "schema": "fake_schema",
+    "schema": "sientia_data",
-    "table_name": "fake_table",
+    "table_name": "laborious_data",
     "retention_time": 3600,
     "model_tags": {
-        "Temperature Sensor": {
+        "Counter": {
             "data_range": [0, 50],
             "aggr_function": "lts"
         },
-        "Vibration Meter": {
+        "Rollout": {
             "data_range": [0, 50],
             "aggr_function": "mdn"
         },
-        "Pressure Gauge": {
+        "Square": {
-            "data_range": [0, 100],
-            "aggr_function": "avg"
-        },
-        "Flow Meter": {
-            "data_range": [0, 100],
-            "aggr_function": "max"
-        },
-        "Voltage Sensor": {
-            "data_range": [0, 100],
-            "aggr_function": "min"
-        },
-        "Current Sensor": {
             "data_range": [0, 100],
             "aggr_function": "avg"
         }

scouter/workflow/scouter.py

@@ -39,7 +39,9 @@ class Scouter:
                 'schedule_name': input_data['schedule_name'],
                 'model_name': input_data['model_name'],
                 'model_id': input_data['model_id']
-            }
+            },
+            retry_policy=retry_policy,
+            start_to_close_timeout=timedelta(seconds=60)
         )
 
         data = await workflow.execute_activity_method(

values.yaml

@@ -169,7 +169,7 @@ env:
     value: "sientia-scouter"
 
   - name: TEMPORAL_HOST
-    value: "temporal.temporal.svc.cluster.local:7233"
+    value: "temporal-frontend.temporal.svc.cluster.local:7233"
   - name: TEMPORAL_NAMESPACE
     value: "default"