fixed errors

seqeralabs · May 30, 2024 · fb88e0a · fb88e0a
1 parent 54f6faf
commit fb88e0a
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/src/main/groovy/io/seqera/wave/service/CredentialServiceImpl.groovy b/src/main/groovy/io/seqera/wave/service/CredentialServiceImpl.groovy
@@ -102,7 +102,7 @@ class CredentialServiceImpl implements CredentialsService {
  }
 
  CredentialsDescription findComputeCreds(PlatformId identity) {
- final describeWorkflowLaunchResponse = towerClient.fetchWorkflowLaunchInfo(identity.towerEndpoint,identity.accessToken,identity.workflowId)
+ final describeWorkflowLaunchResponse = towerClient.fetchWorkflowLaunchInfo(identity.towerEndpoint, JwtAuth.of(identity), identity.workflowId)
  if(describeWorkflowLaunchResponse) {
  ComputeEnv computeEnv = describeWorkflowLaunchResponse.get()?.launch?.computeEnv
  if (computeEnv && (computeEnv.platform == 'aws-batch' || computeEnv.platform == 'google-batch')) {

diff --git a/src/main/groovy/io/seqera/wave/tower/client/TowerClient.groovy b/src/main/groovy/io/seqera/wave/tower/client/TowerClient.groovy
@@ -114,9 +114,9 @@ class TowerClient {
  StringUtils.removeEnd(endpoint, "/")
  }
 
- CompletableFuture<DescribeWorkflowLaunchResponse> fetchWorkflowLaunchInfo(String towerEndpoint, String authorization, String workflowId){
+ CompletableFuture<DescribeWorkflowLaunchResponse> fetchWorkflowLaunchInfo(String towerEndpoint, JwtAuth authorization, String workflowId){
  def uri = workflowLaunchInfoEndpoint(towerEndpoint,workflowId)
- return getAsync(uri, towerEndpoint, authorization,DescribeWorkflowLaunchResponse.class)
+ return getAsync(uri, towerEndpoint, authorization, DescribeWorkflowLaunchResponse.class)
  }
  protected static URI workflowLaunchInfoEndpoint(String towerEndpoint, String workflowId) {
  return URI.create("${checkEndpoint(towerEndpoint)}/workflow/${workflowId}/launch")