diff --git a/project/tasks/danano.go b/project/tasks/danano.go index 8499f08..2b4ee72 100644 --- a/project/tasks/danano.go +++ b/project/tasks/danano.go @@ -6,7 +6,7 @@ import ( func exec_task(arg string) string{ - response := "Ciao danano " + arg + response := "" + arg return response } \ No newline at end of file diff --git a/project/tasks/task1.go b/project/tasks/task1.go index b778dc4..88dfe7e 100644 --- a/project/tasks/task1.go +++ b/project/tasks/task1.go @@ -6,7 +6,7 @@ import ( func exec_task(arg string) string{ - response := "" + arg + response := "Ciao danano " + arg return response } \ No newline at end of file diff --git a/project/workflow.yaml b/project/workflow.yaml index b42ebd2..49c5799 100644 --- a/project/workflow.yaml +++ b/project/workflow.yaml @@ -10,12 +10,12 @@ tasks: dest_topic: aggregated_data component_name: data_aggregation version: 1.0.0 - - name: Daniele pelato + - name: Aiutatemi type: processor_nats code: danano.go targets: - edge - source_topic: temp_sensor - dest_topic: sexo - component_name: liscio + source_topic: test + dest_topic: temp_sensor + component_name: test_producer version: 1.0.0 \ No newline at end of file