export const postOnboardingWorkflow = createWorkflow({
id: "post-onboarding-workflow",
description: "Rank, deduplicate, and research keywords with rankings-first approach",
inputSchema: PostOnboardingWorkflowInputSchema,
outputSchema: PostOnboardingWorkflowOutputSchema,
})
.then(pageRankingStep)
.then(pageDeduplicationStep)
.then(enrichPagesWithContextStep)processing
.foreach(singlePageKeywordStep, { concurrency: RANKING_KEYWORDS_CONFIG.MAX_CONCURRENCY })
.then(keywordCannicalizationCleanupStep)
.commit();
export const postOnboardingWorkflow = createWorkflow({
id: "post-onboarding-workflow",
description: "Rank, deduplicate, and research keywords with rankings-first approach",
inputSchema: PostOnboardingWorkflowInputSchema,
outputSchema: PostOnboardingWorkflowOutputSchema,
})
.then(pageRankingStep)
.then(pageDeduplicationStep)
.then(enrichPagesWithContextStep)processing
.foreach(singlePageKeywordStep, { concurrency: RANKING_KEYWORDS_CONFIG.MAX_CONCURRENCY })
.then(keywordCannicalizationCleanupStep)
.commit();