feat: dynamic crons

Taskfile.yaml

@@ -55,8 +55,8 @@ tasks:
   recreate-db-from-scratch:
     cmds:
       - docker compose down
-      - docker volume rm hatchet_hatchet_postgres_data
-      - docker volume rm hatchet_hatchet_rabbitmq_data
+      - docker volume rm oss_hatchet_postgres_data
+      - docker volume rm oss_hatchet_rabbitmq_data
       - docker compose up -d
       - task: setup
       - task: init-dev-env

api-contracts/openapi/components/schemas/_index.yaml

@@ -234,6 +234,10 @@ RerunStepRunRequest:
   $ref: "./workflow_run.yaml#/RerunStepRunRequest"
 TriggerWorkflowRunRequest:
   $ref: "./workflow_run.yaml#/TriggerWorkflowRunRequest"
+ScheduleWorkflowRunRequest:
+  $ref: "./workflow_run.yaml#/ScheduleWorkflowRunRequest"
+CreateCronWorkflowTriggerRequest:
+  $ref: "./workflow_run.yaml#/CreateCronWorkflowTriggerRequest"
 CreatePullRequestFromStepRun:
   $ref: "./workflow_run.yaml#/CreatePullRequestFromStepRun"
 GetStepRunDiffResponse:

api-contracts/openapi/components/schemas/workflow_run.yaml

@@ -15,6 +15,7 @@ ScheduledWorkflowsOrderByField:
 CronWorkflowsOrderByField:
   type: string
   enum:
+    - name
     - createdAt
 
 WorkflowRunOrderByDirection:
@@ -207,13 +208,23 @@ ScheduledWorkflows:
       minLength: 36
       maxLength: 36
       format: uuid
+    method:
+      $ref: "#/ScheduledWorkflowsMethod"
   required:
     - metadata
     - tenantId
     - workflowVersionId
     - workflowName
     - workflowId
     - triggerAt
+    - method
+
+
+ScheduledWorkflowsMethod:
+  type: string
+  enum:
+    - DEFAULT
+    - API
 
 ScheduledWorkflowsList:
   type: object
@@ -225,6 +236,12 @@ ScheduledWorkflowsList:
     pagination:
       $ref: "./metadata.yaml#/PaginationResponse"
 
+CronWorkflowsMethod:
+  type: string
+  enum:
+    - DEFAULT
+    - API
+
 CronWorkflows:
   type: object
   properties:
@@ -240,19 +257,27 @@ CronWorkflows:
       type: string
     cron:
       type: string
+    name:
+      type: string
     input:
       type: object
       additionalProperties: true
     additionalMetadata:
       type: object
       additionalProperties: true
+    enabled:
+      type: boolean
+    method:
+      $ref: "#/CronWorkflowsMethod"
   required:
     - metadata
     - tenantId
     - workflowVersionId
     - workflowName
     - workflowId
     - cron
+    - enabled
+    - method
 
 CronWorkflowsList:
   type: object
@@ -636,6 +661,36 @@ TriggerWorkflowRunRequest:
   required:
     - input
 
+CreateCronWorkflowTriggerRequest:
+  properties:
+    input:
+      type: object
+    additionalMetadata:
+      type: object
+    cronName:
+      type: string
+    cronExpression:
+      type: string
+  required:
+    - input
+    - additionalMetadata
+    - cronName
+    - cronExpression
+
+ScheduleWorkflowRunRequest:
+  properties:
+    input:
+      type: object
+    additionalMetadata:
+      type: object
+    triggerAt:
+      type: string
+      format: date-time
+  required:
+    - input
+    - additionalMetadata
+    - triggerAt
+
 CreatePullRequestFromStepRun:
   properties:
     branchName:

api-contracts/openapi/openapi.yaml

@@ -116,12 +116,18 @@ paths:
     $ref: "./paths/event/event.yaml#/keys"
   /api/v1/tenants/{tenant}/workflows:
     $ref: "./paths/workflow/workflow.yaml#/withTenant"
+  /api/v1/tenants/{tenant}/workflows/{workflow}/scheduled:
+    $ref: "./paths/workflow/workflow.yaml#/scheduledCreate"
   /api/v1/tenants/{tenant}/workflows/scheduled:
     $ref: "./paths/workflow/workflow.yaml#/scheduledList"
-  /api/v1/tenants/{tenant}/workflows/scheduled/{scheduledId}:
+  /api/v1/tenants/{tenant}/workflows/scheduled/{scheduled-workflow-run}:
     $ref: "./paths/workflow/workflow.yaml#/scheduled"
+  /api/v1/tenants/{tenant}/workflows/{workflow}/crons:
+    $ref: "./paths/workflow/workflow.yaml#/cronsCreate"
   /api/v1/tenants/{tenant}/workflows/crons:
     $ref: "./paths/workflow/workflow.yaml#/cronsList"
+  /api/v1/tenants/{tenant}/workflows/crons/{cron-workflow}:
+    $ref: "./paths/workflow/workflow.yaml#/crons"
   /api/v1/tenants/{tenant}/workflows/cancel:
     $ref: "./paths/workflow/workflow.yaml#/cancelWorkflowRuns"
   /api/v1/workflows/{workflow}: