Skip to content

feat: enable health_score_v2_sink scheduled export (IN-1221) - #4475

Merged
gaspergrom merged 2 commits into
mainfrom
fix/IN-1221-enable-health-score-v2-sink
Aug 13, 2026
Merged

feat: enable health_score_v2_sink scheduled export (IN-1221)#4475
gaspergrom merged 2 commits into
mainfrom
fix/IN-1221-enable-health-score-v2-sink

Conversation

@gaspergrom

@gaspergrom gaspergrom commented Aug 12, 2026

Copy link
Copy Markdown
Contributor

Summary

  • Activates health_score_v2_sink's recurring export, replacing @on-demand (disabled pending product go-ahead) with 35 0 * * * (00:35 UTC), 5 minutes after health_score_sink's 00:30 UTC run.
  • Already validated and running live in Tinybird production on this schedule — this PR brings the source-controlled state on main in sync with what's deployed (main previously reflected the @on-demand version merged via feat: add separate v2 health score sink to snowflake (IN-1212) #4432).
  • Authorized by Joana Maia in Slack alongside enabling overall_score_v2.

Signed-off-by: Gašper Grom <gasper.grom@gmail.com>
Copilot AI balanced review requested due to automatic review settings August 12, 2026 21:32
@cursor

cursor Bot commented Aug 12, 2026

Copy link
Copy Markdown

PR Summary

Low Risk
Single Tinybird pipe schedule change with no query or sink wiring changes; production is already on this cron.

Overview
Enables the recurring Kafka export for health_score_v2_sink by replacing EXPORT_SCHEDULE @on-demand with 35 0 * * * (daily at 00:35 UTC).

That timing runs five minutes after health_score_sink’s 30 0 * * * job so v2 health/impact fields stream on a predictable cadence instead of manual tb pipe sink run. The PR description notes production Tinybird already uses this schedule; this change aligns main with what’s deployed.

Reviewed by Cursor Bugbot for commit b6f1321. Bugbot is set up for automated code reviews on this repo. Configure here.

Copilot AI left a comment

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Pull request overview

Activates the Health Score v2 Tinybird sink for daily Kafka exports.

Changes:

  • Replaces on-demand execution with a 00:35 UTC schedule.

💡 Add a code-review agent skill or configure MCP servers for context-aware, tailored reviews. Learn more in the docs.

EXPORT_SERVICE kafka
EXPORT_CONNECTION_NAME lfx-oracle-kafka-streaming
EXPORT_SCHEDULE @on-demand
EXPORT_SCHEDULE 35 0 * * *
Copilot AI review requested due to automatic review settings August 13, 2026 08:38
@gaspergrom
gaspergrom merged commit ba74a0c into main Aug 13, 2026
13 checks passed
@gaspergrom
gaspergrom deleted the fix/IN-1221-enable-health-score-v2-sink branch August 13, 2026 08:38

Copilot AI left a comment

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Pull request overview

Copilot reviewed 1 out of 1 changed files in this pull request and generated no new comments.

Suppressed comments (1)

services/libs/tinybird/pipes/health_score_v2_sink.pipe:45

  • This runs before both datasets read by the sink are refreshed: project_insights_impact_breakdown_copy.pipe runs at 02:40 UTC and project_insights_copy.pipe at 03:00 UTC. The 00:35 job therefore exports the previous refresh while stamping rows with the new day's date. Schedule it after 03:00 with a buffer, as the dependency documentation recommends.
EXPORT_SCHEDULE 35 0 * * *

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants