File tree Expand file tree Collapse file tree
apps/packages_worker/src/deps-dev/queries
libs/data-access-layer/src/osspckgs Expand file tree Collapse file tree Original file line number Diff line number Diff line change 2222FROM \`bigquery-public-data.deps_dev_v1.GoRequirementsLatest\` g,
2323UNNEST(g.DirectDependencies) AS d`
2424
25- // NuGet groups deps by TargetFramework — flatten all groups, dedup handled downstream
26- // by ON CONFLICT in MERGE_SQL (and DISTINCT ON in the fill-constraints variant).
25+ // NuGet groups deps by TargetFramework — flatten all groups, duplicate (root, dep) pairs are
26+ // deduped downstream by DISTINCT ON + ON CONFLICT in MERGE_SQL (and the fill-constraints variant).
2727const NUGET_FULL_PART = `
2828SELECT
2929 'nuget' AS ecosystem,
Original file line number Diff line number Diff line change @@ -86,8 +86,6 @@ export async function findLatestExportedJobByKind(
8686 : null
8787}
8888
89- // Returns an existing exported job for the given GCS prefix so callers can
90- // skip re-running the BQ export when retrying a failed workflow.
9189// Loads the fields needed to resume a partially-merged chunked job by id: the exact GCS export
9290// path (so the same parquet files — and therefore the same chunk boundaries — are re-listed) plus
9391// the file-level load progress and rows-merged-so-far. progressDone/progressTotal come from the
@@ -139,6 +137,8 @@ export async function getIngestJobForResume(
139137 : null
140138}
141139
140+ // Returns an existing exported job for the given GCS prefix so callers can
141+ // skip re-running the BQ export when retrying a failed workflow.
142142export async function findExportedJobByGcsPrefix (
143143 qx : QueryExecutor ,
144144 gcsPrefix : string ,
You can’t perform that action at this time.
0 commit comments