[SELC-5561] feat: call CREATE_AGGREGATES_CSV_ACTIVITY function in Wor…

…kflowExecutorIncrementRegistrationAggregator (#522)
pagopa · Oct 4, 2024 · 6570904 · 6570904
1 parent 7827edb
commit 6570904
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/.../pagopa/selfcare/onboarding/workflow/WorkflowExecutorIncrementRegistrationAggregator.java b/.../pagopa/selfcare/onboarding/workflow/WorkflowExecutorIncrementRegistrationAggregator.java
@@ -12,12 +12,15 @@
 import java.util.Optional;
 
 import static it.pagopa.selfcare.onboarding.entity.OnboardingWorkflowType.AGGREGATOR;
+import static it.pagopa.selfcare.onboarding.functions.utils.ActivityName.BUILD_CONTRACT_ACTIVITY_NAME;
+import static it.pagopa.selfcare.onboarding.utils.Utils.getOnboardingWorkflowString;
 
 public record WorkflowExecutorIncrementRegistrationAggregator(ObjectMapper objectMapper, TaskOptions optionsRetry,
                                                               OnboardingMapper onboardingMapper) implements WorkflowExecutor {
 
     @Override
     public Optional<OnboardingStatus> executeRequestState(TaskOrchestrationContext ctx, OnboardingWorkflow onboardingWorkflow) {
+        ctx.callActivity(BUILD_CONTRACT_ACTIVITY_NAME, getOnboardingWorkflowString(objectMapper, onboardingWorkflow), optionsRetry, String.class).await();
         return Optional.empty();
     }