remove some logging

broadinstitute · Dec 12, 2024 · ff63cdd · ff63cdd
1 parent 158ceaf
commit ff63cdd
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 13 deletions.
diff --git a/.github/workflows/test_illumina_genotyping_array.yml b/.github/workflows/test_illumina_genotyping_array.yml
@@ -236,7 +236,7 @@ jobs:
             done
           done
 
-          echo "All jobs have been submitted. Now starting polling for statuses..."
+          echo "All jobs have been submitted. Starting to poll for statuses..."
 
           # 2. After all submissions are done, start polling for statuses of all jobs
           for SUBMISSION_ID in "${SUBMISSION_IDS[@]}"; do
@@ -260,15 +260,8 @@ jobs:
                   sleep $RETRY_DELAY
                   continue
               fi
-
-              echo "Raw Workflow Statuses:"
-              echo "$RESPONSE"
 
               WORKFLOW_STATUSES_FOR_SUBMISSION=$(echo "$RESPONSE" | jq -r 'to_entries | map(.key + " | " + .value) | .[]')
-              echo "Statuses for submission $SUBMISSION_ID:"
-              echo "$WORKFLOW_STATUSES_FOR_SUBMISSION"
-
-              echo "Appending to aggregate statuses"
               WORKFLOW_STATUSES["$SUBMISSION_ID"]="$WORKFLOW_STATUSES_FOR_SUBMISSION"
 
               # retrieve workflow outputs

diff --git a/scripts/firecloud_api/firecloud_api2.py b/scripts/firecloud_api/firecloud_api2.py
@@ -150,15 +150,13 @@ def poll_job_status(self, submission_id):
 
         # Continuously poll the status of the submission until completion
         while True:
-            logging.info(f"Polling submission ID: {submission_id}")
             status_response = requests.get(status_url, headers=self.headers)
 
             # Check if the response status code is successful (200)
             if status_response.status_code != 200:
                 logging.error(f"Error: Received status code {status_response.status_code}", file=sys.stderr)
                 logging.info(f"Response content: {status_response.text}", file=sys.stderr)
                 return {}
-
             try:
                 # Parse the response as JSON
                 status_data = status_response.json()
@@ -174,9 +172,6 @@ def poll_job_status(self, submission_id):
                 workflow_status = workflow.get("status")
                 if workflow_id and workflow_status:
                     workflow_status_map[workflow_id] = workflow_status
-                    logging.info(f"Workflow ID: {workflow_id}, Status: {workflow_status}")
-                    #print the dictionary
-                    print(json.dumps(workflow_status_map))
 
             # Check if the submission is complete
             submission_status = status_data.get("status", "")