Skip to content

Commit 0b03672

Browse files
committed
Replaying should copy over the metadata
1 parent 9a80f47 commit 0b03672

File tree

2 files changed

+14
-0
lines changed

2 files changed

+14
-0
lines changed

apps/webapp/app/v3/services/replayTaskRun.server.ts

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -65,6 +65,13 @@ export class ReplayTaskRunService extends BaseService {
6565
payloadPacketType: payloadPacket.dataType,
6666
});
6767

68+
const metadata = existingTaskRun.metadata
69+
? await parsePacket({
70+
data: existingTaskRun.metadata,
71+
dataType: existingTaskRun.metadataType,
72+
})
73+
: undefined;
74+
6875
try {
6976
const tags = await getTagsForRunId({
7077
friendlyId: existingTaskRun.friendlyId,
@@ -85,6 +92,7 @@ export class ReplayTaskRunService extends BaseService {
8592
test: existingTaskRun.isTest,
8693
payloadType: payloadPacket.dataType,
8794
tags: tags?.map((t) => t.name) as RunTags,
95+
metadata,
8896
},
8997
},
9098
{

references/v3-catalog/src/trigger/runMetadata.ts

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -43,6 +43,12 @@ export const runMetadataChildTask = task({
4343
metadata: metadata.current(),
4444
});
4545
},
46+
onStart: async () => {
47+
logger.info("metadata", { metadata: metadata.current() });
48+
},
49+
onSuccess: async () => {
50+
logger.info("metadata", { metadata: metadata.current() });
51+
},
4652
});
4753

4854
export const runMetadataChildTask2 = task({

0 commit comments

Comments
 (0)