[schellar] workflow_context as a json

FRINXio · Aug 13, 2024 · e3ec320 · e3ec320
1 parent 912b0ed
commit e3ec320
Show file tree

Hide file tree

Showing 4 changed files with 9 additions and 5 deletions.
diff --git a/schellar/python/CHANGELOG.md b/schellar/python/CHANGELOG.md
@@ -7,3 +7,7 @@
 # 1.1.0
 - Update dependencies
 - Add response handler with task Failed status
+
+# 1.2.0
+workflow_context as a JSON input in workflow
+changes stringify on workflow_context worker input
diff --git a/schellar/python/frinx_worker/schellar/__init__.py b/schellar/python/frinx_worker/schellar/__init__.py
@@ -217,7 +217,7 @@ def execute(self, worker_input: WorkerInput) -> TaskResult[WorkerOutput]:
             )
 
             if worker_input.workflow_context:
-                create_schedule.input.workflow_context = json_dumps(worker_input.workflow_context).replace('"', '\\"')
+                create_schedule.input.workflow_context = json_dumps(worker_input.workflow_context)
 
             mutation = create_schedule.render(form="extracted")
             response = execute_schellar_query(query=mutation.query, variables=mutation.variable)
@@ -279,7 +279,7 @@ def execute(self, worker_input: WorkerInput) -> TaskResult[WorkerOutput]:
             )
 
             if worker_input.workflow_context:
-                update_schedule.input.workflow_context = json_dumps(worker_input.workflow_context).replace('"', '\\"')
+                update_schedule.input.workflow_context = json_dumps(worker_input.workflow_context)
 
             mutation = update_schedule.render()
             response = execute_schellar_query(query=mutation.query, variables=mutation.variable)

diff --git a/schellar/python/frinx_worker/schellar/workflows/schellar.py b/schellar/python/frinx_worker/schellar/workflows/schellar.py
@@ -63,7 +63,7 @@ class WorkflowInput(WorkflowImpl.WorkflowInput):
                 name="workflow_context",
                 frontend_default_value="",
                 description="Workflow input parameters in json format",
-                type=FrontendWFInputFieldType.STRING,
+                type=FrontendWFInputFieldType.JSON,
             )
 
             from_date: WorkflowInputField = WorkflowInputField(
@@ -159,7 +159,7 @@ class WorkflowInput(WorkflowImpl.WorkflowInput):
                 name="workflow_context",
                 frontend_default_value="",
                 description="Workflow input parameters in json format",
-                type=FrontendWFInputFieldType.STRING,
+                type=FrontendWFInputFieldType.JSON,
             )
 
             from_date: WorkflowInputField = WorkflowInputField(

diff --git a/schellar/python/pyproject.toml b/schellar/python/pyproject.toml
@@ -19,7 +19,7 @@ packages = [{ include = "frinx_worker" }]
 name = "frinx-schellar-worker"
 description = "Conductor worker for Schellar service"
 authors = ["Jozef Volak <[email protected]>"]
-version = "1.1.1"
+version = "1.2.0"
 readme = ["README.md", "CHANGELOG.md", "RELEASE.md"]
 keywords = ["frinx-machine", "schellar", "worker"]
 license = "Apache 2.0"