fix: members_sorted schedule#4376
Conversation
Signed-off-by: anilb <epipav@gmail.com>
|
Your PR title doesn't contain a Jira issue key. Consider adding it for better traceability. Example:
Projects:
Please add a Jira issue key to your PR title. |
PR SummaryLow Risk Overview That datasource is what downstream activity-relations bucket clean/enrich copy pipes use for valid-member filtering ( Reviewed by Cursor Bugbot for commit dcf457e. Bugbot is set up for automated code reviews on this repo. Configure here. |
|
|
There was a problem hiding this comment.
Pull request overview
Moves the hourly members_sorted Tinybird refresh from minute 8 to minute 36.
Changes:
- Updates the copy schedule to
36 * * * *. - PR title is missing the required
(CM-XXX)JIRA key.
💡 Add Copilot custom instructions for smarter, more guided reviews. Learn how to get started.
|
lgtm |
There was a problem hiding this comment.
Pull request overview
Copilot reviewed 1 out of 1 changed files in this pull request and generated no new comments.
Comments suppressed due to low confidence (1)
services/libs/tinybird/pipes/members_sorted_copy_pipe.pipe:26
- This now runs after all hourly clean/enrich consumers, which read
members_sortedat minutes :10–:26 to filter valid members (activityRelations_bucket_clean_enrich_copy_pipe_{0..9}.pipe; seebucketing-architecture.md:118-143). They will therefore process the previous hour's member snapshot. Keep this refresh before :10, or reschedule every dependent consumer after :36.
COPY_SCHEDULE 36 * * * *
There was a problem hiding this comment.
Pull request overview
Copilot reviewed 1 out of 1 changed files in this pull request and generated no new comments.
Comments suppressed due to low confidence (1)
services/libs/tinybird/pipes/members_sorted_copy_pipe.pipe:26
- This now refreshes
members_sortedafter every hourlyactivityRelations_bucket_clean_enrich_copy_pipe_*consumer (scheduled at minutes 10–26) and aftercontributions_with_local_timeat minute 33. Those jobs will therefore always read the previous hour's member snapshot, delaying bot/team-member filtering and profile updates by another cycle. Keep this producer before the earliest dependent copy, or move all dependent schedules after minute 36.
COPY_SCHEDULE 36 * * * *
No description provided.