diff --git a/.github/workflows/deploy-hubs.yaml b/.github/workflows/deploy-hubs.yaml
index d8ea4f834..173383fdf 100644
--- a/.github/workflows/deploy-hubs.yaml
+++ b/.github/workflows/deploy-hubs.yaml
@@ -501,7 +501,7 @@ jobs:
   # filtering out any deployment to a cluster with a failed staging hub job.
   filter-failed-staging-jobs:
     runs-on: ubuntu-latest
-    needs: [generate-jobs, filter-failed-support-jobs, upgrade-staging]
+    needs: [generate-jobs, filter-failed-support-jobs, upgrade-staging-hubs]
     if: |
       !cancelled() &&
       (github.event_name == 'push' && contains(github.ref, 'main')) &&
@@ -523,7 +523,7 @@ jobs:
           import json
 
           prod_jobs = json.loads(r"""${{ needs.filter-failed-support-jobs.outputs.filtered-prod-hub-matrix-jobs }}""")
-          outputs = json.loads(r"""${{ toJson(needs.upgrade-staging.outputs) }}""")
+          outputs = json.loads(r"""${{ toJson(needs.upgrade-staging-hubs.outputs) }}""")
 
           try:
             filtered_prod_jobs = [
@@ -532,7 +532,7 @@ jobs:
                 if outputs[f"failure_{prod_job['cluster_name'].replace('.', '-')}"] != "true"
             ]
           except KeyError:
-            print(f"The {cluster_name} cluster wasn't found in the `upgrade-staging.outputs` list. Please add it before continuing!")
+            print(f"The {cluster_name} cluster wasn't found in the `upgrade-staging-hubs.outputs` list. Please add it before continuing!")
 
           env_file = os.getenv("GITHUB_ENV")
           with open(env_file, "a") as f: