public void executeInternal()

in ddm-bpm-extension/src/main/java/com/epam/digital/data/platform/bpms/extension/delegate/connector/DataFactoryConnectorBatchCreateDelegateV2.java [65:83]

• 16 lines of code
• 3 McCabe index (conditional complexity)

  public void executeInternal(DelegateExecution execution) throws Exception {
    responseVariable.on(execution).set(ConnectorResponse.builder().build());

    var resource = resourceVariable.from(execution).get();
    var payload = payloadVariable.from(execution).getOrDefault(Spin.JSON(Map.of()));
    var uploadTypeString = uploadType.from(execution).getOrThrow();

    log.debug("Start executing batch create entities on resource {}, using {} upload type", resource, uploadTypeString);
    ConnectorResponse response = null;
    if (LIST.toString().equals(uploadTypeString)) {
      var dataFactoryPayload = Spin.JSON(Map.of("entities", payload.unwrap()));
      response = executeBatchCreateOperation(execution, dataFactoryPayload, resource, uploadTypeString);
    } else if (CSV.toString().equals(uploadTypeString)) {
      response = executeBatchCreateOperation(execution, payload, resource, uploadTypeString);
    }
    log.debug("Finished batch create operation");

    responseVariable.on(execution).set(response);
  }