apunkt/ktx
1
0
Fork 0
mirror of https://github.com/Kaelio/ktx.git synced 2026-06-10 08:05:14 +02:00
Code Issues Projects Releases Packages Wiki Activity

test(ingest): verify metricflow isolated projection path

Browse source
This commit is contained in:
Andrey Avtomonov 2026-05-18 02:40:55 +02:00
parent b6b63123f8
commit 2348a737c7
2 changed files with 17 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

12
packages/context/src/ingest/ingest-bundle.runner.ts
View file

@ -1337,6 +1337,7 @@ export class IngestBundleRunner {
});
if (adapter.project) {
const preProjectionSha = await sessionWorktree.git.revParseHead();
const projection = await traceTimed(
runTrace,
'projection',
@ -1379,7 +1380,10 @@ export class IngestBundleRunner {
this.deps.storage.systemGitAuthor.name,
this.deps.storage.systemGitAuthor.email,
);
isolatedDiffSummary.projectionSha = projectionCommit.created ? projectionCommit.commitHash : null;
isolatedDiffSummary.projectionSha =
projectionCommit.created || projectionCommit.commitHash !== preProjectionSha
? projectionCommit.commitHash
: null;
await runTrace.event('debug', 'projection', 'deterministic_projection_committed', {
projectionSha: isolatedDiffSummary.projectionSha,
touchedSources: projectionTouchedSources,
@ -1648,8 +1652,10 @@ export class IngestBundleRunner {
throw new Error(`isolated diff semantic conflict in ${outcome.unitKey}: ${integration.reason}`);
}
activeFailureDetails = undefined;
isolatedDiffSummary.acceptedPatches += 1;
integratedPatchCount += 1;
if (integration.touchedPaths.length > 0) {
isolatedDiffSummary.acceptedPatches += 1;
integratedPatchCount += 1;
}
emitStageProgress(
'integration',
83,

8
packages/context/src/ingest/local-bundle-ingest.test.ts
View file

@ -694,6 +694,14 @@ describe('canonical local ingest', () => {
],
},
});
expect(result.report.body.isolatedDiff).toMatchObject({
enabled: true,
acceptedPatches: 0,
projectionSha: expect.any(String),
});
const projectedSourcePath = join(metricflowProject.projectDir, 'semantic-layer/warehouse/orders.yaml');
await expect(readFile(projectedSourcePath, 'utf-8')).resolves.toContain('name: orders');
const stagedRawPath = join(
metricflowProject.projectDir,