File tree Expand file tree Collapse file tree 2 files changed +14
-0
lines changed
apps/webapp/app/v3/services
references/v3-catalog/src/trigger Expand file tree Collapse file tree 2 files changed +14
-0
lines changed Original file line number Diff line number Diff 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 {
Original file line number Diff line number Diff 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
4854export const runMetadataChildTask2 = task ( {
You can’t perform that action at this time.
0 commit comments