docs: @Override
      protected final QueryResult executeWorkFlow(LogicalWorkflow workflow) throws ConnectorException {
  
          checkIsSupported(workflow);
          ClusterName clusterName = ((Project) workflow.getInitialSteps().get(0)).getClusterName();
  
          return execute((Project) workflow.getInitialSteps().get(0),
                  connectionHandler.getConnection(clusterName.getName()));
      }