diff --git a/pkg/cron_workflow.go b/pkg/cron_workflow.go index 1e6db48..9d798f9 100644 --- a/pkg/cron_workflow.go +++ b/pkg/cron_workflow.go @@ -256,6 +256,7 @@ func (c *Client) CreateCronWorkflow(namespace string, cronWorkflow *CronWorkflow "workflow_template_version_id": workflowTemplate.WorkflowTemplateVersionId, "manifest": cronWorkflow.Manifest, "namespace": namespace, + "is_archived": false, }). Suffix("RETURNING id"). RunWith(tx). diff --git a/pkg/workflow_execution.go b/pkg/workflow_execution.go index 67cd8b9..526c75f 100644 --- a/pkg/workflow_execution.go +++ b/pkg/workflow_execution.go @@ -425,6 +425,7 @@ func (c *Client) insertPreWorkflowExecutionStatistic(namespace, name string, wor "created_at": createdAt.UTC(), "phase": wfv1.NodePending, "parameters": string(parametersJson), + "is_archived": false, } err = sb.Insert("workflow_executions").