`
export const startWorkflow = internalMutation({
args: {
userId: v.id('users'),
repoId: v.id('repos'),
},
async handler(ctx, args) {
let savedRepo = await ctx.db.get(args.repoId)
if (!savedRepo) return err('repo not found')
let startSync = new Date().toISOString()
await workflow.start(
ctx,
internal.services.sync.backfillRepoWorkflow,
{
userId: args.userId,
repoId: savedRepo._id,
},
{
onComplete: internal.services.sync.finishBackfill,
context: {
repoId: savedRepo._id,
backfillStartedAt: startSync,
} satisfies FinishBackfillArgs['context'],
},
)
},
})
`
export const startWorkflow = internalMutation({
args: {
userId: v.id('users'),
repoId: v.id('repos'),
},
async handler(ctx, args) {
let savedRepo = await ctx.db.get(args.repoId)
if (!savedRepo) return err('repo not found')
let startSync = new Date().toISOString()
await workflow.start(
ctx,
internal.services.sync.backfillRepoWorkflow,
{
userId: args.userId,
repoId: savedRepo._id,
},
{
onComplete: internal.services.sync.finishBackfill,
context: {
repoId: savedRepo._id,
backfillStartedAt: startSync,
} satisfies FinishBackfillArgs['context'],
},
)
},
})