Skip to content

Conversation

hsinfang
Copy link
Collaborator

No description provided.

Copy link
Member

@kfindeisen kfindeisen left a comment

Choose a reason for hiding this comment

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

Looks good! The dependency on get_exp_id_from_oid is a bit awkward, but I don't see a better way.

@hsinfang hsinfang force-pushed the tickets/DM-48048 branch 2 times, most recently from b60dd25 to a6f1bc1 Compare July 15, 2025 00:24
hsinfang added 3 commits July 15, 2025 10:56
We have seen cases where one same file was picked up from the raw
microservice, and later picked up again from bucket arrival
notification, probably due to Kafka delays.

Add a check so to ingest raws only if it is not known to be
already ingested.
Because we do not know the exposure-snap mapping, check all snaps
despite that some might have already been handled.
@hsinfang hsinfang merged commit 14a4ca6 into main Jul 15, 2025
11 checks passed
@hsinfang hsinfang deleted the tickets/DM-48048 branch July 15, 2025 23:48
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.

2 participants