Janky Fix: Extract input payloads for standalone tasks for dashboard (#3128)

* fix: extract input payload correctly

* chore: todo -> fixme

* fix: naming + handle panic

Author: mrkaye97

api/v1/server/oas/transformers/v1/tasks.go

@@ -258,6 +258,16 @@ func ToTask(taskWithData *v1.TaskWithPayloads, workflowRunExternalId uuid.UUID,
 
 	input := jsonToMap(taskWithData.InputPayload)
 
+	if taskWithData.IsStandalone {
+		// fixme: improve this somehow - it's using this implicit assumption about how
+		// we structure payloads, which it shouldn't
+		if inputWithInternalHatchetData, ok := input["input"]; ok {
+			if actualInput, ok := inputWithInternalHatchetData.(map[string]interface{}); ok {
+				input = actualInput
+			}
+		}
+	}
+
 	stepId := taskWithData.StepID
 
 	retryCount := int(taskWithData.RetryCount)

pkg/repository/olap.go

@@ -648,6 +648,7 @@ func (r *OLAPRepositoryImpl) ReadTaskRunData(ctx context.Context, tenantId uuid.
 			ErrorMessage:          taskRun.ErrorMessage,
 			RetryCount:            taskRun.RetryCount,
 			OutputEventExternalID: taskRun.OutputEventExternalID,
+			IsStandalone:          taskRun.IsStandalone,
 		},
 		input,
 		output,

pkg/repository/sqlcv1/olap.sql

@@ -511,6 +511,7 @@ WITH selected_retry_count AS (
 )
 SELECT
     t.*,
+    (t.dag_id IS NULL)::BOOLEAN AS is_standalone,
     st.readable_status::v1_readable_status_olap as status,
     f.finished_at::timestamptz as finished_at,
     s.started_at::timestamptz as started_at,
@@ -567,7 +568,8 @@ WITH input AS (
         t.readable_status,
         t.parent_task_external_id,
         t.workflow_run_id,
-        t.latest_retry_count
+        t.latest_retry_count,
+        t.dag_id
     FROM
         v1_tasks_olap t
     JOIN
@@ -689,6 +691,7 @@ SELECT
     END::JSONB AS input,
     t.readable_status::v1_readable_status_olap as status,
     t.workflow_run_id,
+    (t.dag_id IS NULL)::BOOLEAN AS is_standalone,
     f.finished_at::timestamptz as finished_at,
     s.started_at::timestamptz as started_at,
     q.queued_at::timestamptz as queued_at,