Function createActivity

packages/infra/src/WorkflowEngineSqlite.ts:347–360

(
    executionId: string,
    name: string,
    attempt: number,
    encoded: string
  )

  // First-writer-wins persistence of an activity result; returns true if this
  // call won, false if another writer beat us to the (exec, name, attempt) row.
  const createActivity = (
    executionId: string,
    name: string,
    attempt: number,
    encoded: string
  ): Effect.Effect<boolean> =>
    exec(
      `INSERT INTO "${activityTable}" (execution_id, name, attempt, result)
       VALUES (?, ?, ?, ?)
       ON CONFLICT DO NOTHING
       RETURNING execution_id`,
      [executionId, name, attempt, encoded]
    )
      .pipe(Effect.map((rows) => (rows as ReadonlyArray<unknown>).length > 0))

  // Overwrites a previously persisted *suspended* activity result so the next
  // attempt can record its real outcome.