Variables

{
  variables: {
    orgId: { type: "param" },
    startDate: { type: "dateOffset", days: -30 },
  },
  steps: [
    {
      service: "shopify",
      operation: "listOrders",
      params: {
        orgId: "{{var.orgId}}",
        created_at_min: "{{var.startDate}}",
      },
      outputTable: "raw_orders",
      outputSchema: { ... },
    },
  ],
}

variables: {
  orgId: { type: "param" },
  includeArchived: { type: "param", optional: true, default: false },
}

variables: {
  startDate: { type: "dateOffset", days: -30 },
  endDate: { type: "dateOffset", days: 0 },
}

variables: {
  syncTimestamp: { type: "now" },
}

params: {
  orgId: "{{var.orgId}}",
  created_at_min: "{{var.startDate}}",
}

sql: `
  SELECT *
  FROM raw_orders
  WHERE created_at >= '{{var.startDate}}'
    AND org_id = '{{var.orgId}}'
`

branch: {
  condition: "{{var.includeOptionalSync}}",
}

params: {
  orgId: "{{var.orgId}}",
  userId: "{{item.user_id}}",
  since: "{{var.startDate}}",
}

await client.submitJob({
  job: syncOrders,
  params: {
    orgId: "org_abc123",
    appId: "my-app",
  },
});

{
  "workflow": "./src/server/workflows/syncOrders.ts",
  "params": {
    "orgId": "org_abc123",
    "appId": "my-app"
  }
}