[issue-368] knative integration with DataIndex and JobService: fix wo…

…rkflow deletion hanging issue
apache · Sep 6, 2024 · db0c4bd · db0c4bd
1 parent 449afcf
commit db0c4bd
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 2 deletions.
diff --git a/controllers/profiles/common/constants/platform_services.go b/controllers/profiles/common/constants/platform_services.go
@@ -37,7 +37,6 @@ const (
 	JobServiceJobEventsPath                         = "/v2/jobs/events"
 	JobServiceLeaderCheckExpirationInSeconds        = "kogito.jobs-service.management.leader-check.expiration-in-seconds"
 	DefaultJobServiceLeaderCheckExpirationInSeconds = "60"
-	JobServiceRequestEventsURL                      = "mp.messaging.outgoing.kogito-job-service-job-request-events.url"
 
 	KogitoProcessInstancesEventsConnector       = "mp.messaging.outgoing.kogito-processinstances-events.connector"
 	KogitoProcessInstancesEventsMethod          = "mp.messaging.outgoing.kogito-processinstances-events.method"

diff --git a/controllers/sonataflow_controller.go b/controllers/sonataflow_controller.go
@@ -129,7 +129,7 @@ func (r *SonataFlowReconciler) setDefaults(workflow *operatorapi.SonataFlow) {
 
 func (r *SonataFlowReconciler) cleanupTriggers(ctx context.Context, workflow *operatorapi.SonataFlow) error {
 	plf, _ := platform.GetActivePlatform(ctx, r.Client, workflow.Namespace)
-	if plf == nil || len(plf.Status.Triggers) == 0 {
+	if plf == nil || len(workflow.Status.Triggers) == 0 {
 		return nil
 	}
 	avail, err := knative.GetKnativeAvailability(r.Config)