diff --git a/orchestrator/activities/temporal_manager.py b/orchestrator/activities/temporal_manager.py index 7d76176..e29f49a 100644 --- a/orchestrator/activities/temporal_manager.py +++ b/orchestrator/activities/temporal_manager.py @@ -110,7 +110,7 @@ class TemporalManager(BaseActivity): frequency = desc.schedule.spec.intervals[0].every.seconds - orchestrated_schedules[schedule_id] = { + orchestrated_schedules[namespace][schedule_id] = { 'frequency': frequency, 'data': json.loads(data), } diff --git a/test.ipynb b/test.ipynb index 7a97f4b..1fcad1d 100644 --- a/test.ipynb +++ b/test.ipynb @@ -136,7 +136,7 @@ }, { "cell_type": "code", - "execution_count": 4, + "execution_count": null, "id": "bb750ae6", "metadata": {}, "outputs": [ @@ -163,9 +163,9 @@ ")\n", "from temporalio.common import TypedSearchAttributes, SearchAttributeKey, SearchAttributePair\n", "\n", - "# temporal operator search-attribute create --namespace default --name model_id --type Text\n", - "# temporal operator search-attribute create --namespace default --name orchestrated --type Text\n", - "# temporal operator search-attribute create --namespace default --name model_name --type Text\n", + "# temporal operator search-attribute create --namespace scouter --name model_id --type Text && temporal operator search-attribute create --namespace scouter --name orchestrated --type Text && temporal operator search-attribute create --namespace scouter --name model_name --type Text && temporal operator search-attribute create --namespace laborious --name model_id --type Text && temporal operator search-attribute create --namespace laborious --name orchestrated --type Text && temporal operator search-attribute create --namespace laborious --name model_name --type Text\n", + "\n", + "\n", "\n", "await temporal_client.create_schedule(\n", " \"orchestrator\",\n",