@@ -537,7 +537,7 @@ func createEventsReporter(ctx context.Context, cloneOpts *git.CloneOptions, opts
537537 return err
538538 }
539539
540- if err := createSensor (repofs , store .Get ().EventsReporterName , resPath , opts .RuntimeName , store .Get ().EventsReporterName , "events" ); err != nil {
540+ if err := createSensor (repofs , store .Get ().EventsReporterName , resPath , opts .RuntimeName , store .Get ().EventsReporterName , "events" , "data" ); err != nil {
541541 return err
542542 }
543543
@@ -571,7 +571,7 @@ func createWorkflowReporter(ctx context.Context, cloneOpts *git.CloneOptions, op
571571 return err
572572 }
573573
574- if err := createSensor (repofs , store .Get ().WorkflowReporterName , resPath , opts .RuntimeName , store .Get ().WorkflowReporterName , "workflows" ); err != nil {
574+ if err := createSensor (repofs , store .Get ().WorkflowReporterName , resPath , opts .RuntimeName , store .Get ().WorkflowReporterName , "workflows" , "data.object" ); err != nil {
575575 return err
576576 }
577577
@@ -738,14 +738,15 @@ func createWorkflowReporterEventSource(repofs fs.FS, path, namespace string) err
738738 return repofs .WriteYamls (repofs .Join (path , "event-source.yaml" ), eventSource )
739739}
740740
741- func createSensor (repofs fs.FS , name , path , namespace , eventSourceName , trigger string ) error {
741+ func createSensor (repofs fs.FS , name , path , namespace , eventSourceName , trigger , dataKey string ) error {
742742 sensor := eventsutil .CreateSensor (& eventsutil.CreateSensorOptions {
743743 Name : name ,
744744 Namespace : namespace ,
745745 EventSourceName : eventSourceName ,
746746 EventBusName : store .Get ().EventBusName ,
747747 TriggerURL : cfConfig .GetCurrentContext ().URL + store .Get ().EventReportingEndpoint ,
748748 Triggers : []string {trigger },
749+ TriggerDestKey : dataKey ,
749750 })
750751 return repofs .WriteYamls (repofs .Join (path , "sensor.yaml" ), sensor )
751752}
0 commit comments