diff --git a/.github/workflows/periodic-integration-tests.yml b/.github/workflows/periodic-integration-tests.yml
index 0be0c48c9..5d761e05c 100644
--- a/.github/workflows/periodic-integration-tests.yml
+++ b/.github/workflows/periodic-integration-tests.yml
@@ -1,9 +1,6 @@
 name: Periodic Integration Tests
 
 on:
-  push:
-    branches:
-      - "eng-2639-add-automated-periodic-testing-coverage"
   schedule:
     - cron: "0 12 * * 1-5" # Run at 4AM PST on every weekday
   workflow_dispatch:
@@ -155,21 +152,21 @@ jobs:
         run: python3 teardown_hosted.py --aws-key-id ${{ secrets.SAURAV_AWS_ACCESS_KEY_ID }} --aws-secret-key ${{ secrets.SAURAV_AWS_SECRET_ACCESS_KEY }}
 
       # Sets it as an environmental variable.
-      # - name: Get the Slack ID for the current oncall
-      #   if: always()
-      #   run: |
-      #     aws s3 cp s3://aqueduct-assets/oncall.yml ./oncall.yml
-      #     echo "ONCALL_SLACK_MEMBER_ID=$(python3 scripts/get_current_oncall.py --file ./oncall.yml)" >> $GITHUB_ENV
-
-      # - name: Report to Slack on Failure
-      #   if: always()
-      #   uses: ravsamhq/notify-slack-action@v1
-      #   with:
-      #     status: ${{ job.status }}
-      #     notification_title: ""
-      #     message_format: "{emoji} *{workflow}* has {status_message}"
-      #     footer: "{run_url}"
-      #     notify_when: "failure,warnings"
-      #     mention_users: ${{ env.ONCALL_SLACK_MEMBER_ID }}
-      #   env:
-      #     SLACK_WEBHOOK_URL: ${{ secrets.ACTION_MONITORING_SLACK }}
+      - name: Get the Slack ID for the current oncall
+        if: always()
+        run: |
+          aws s3 cp s3://aqueduct-assets/oncall.yml ./oncall.yml
+          echo "ONCALL_SLACK_MEMBER_ID=$(python3 scripts/get_current_oncall.py --file ./oncall.yml)" >> $GITHUB_ENV
+
+      - name: Report to Slack on Failure
+        if: always()
+        uses: ravsamhq/notify-slack-action@v1
+        with:
+          status: ${{ job.status }}
+          notification_title: ""
+          message_format: "{emoji} *{workflow}* has {status_message}"
+          footer: "{run_url}"
+          notify_when: "failure,warnings"
+          mention_users: ${{ env.ONCALL_SLACK_MEMBER_ID }}
+        env:
+          SLACK_WEBHOOK_URL: ${{ secrets.ACTION_MONITORING_SLACK }}
diff --git a/integration_tests/sdk/setup_integration.py b/integration_tests/sdk/setup_integration.py
index a9e50bdf8..89ba0c81c 100644
--- a/integration_tests/sdk/setup_integration.py
+++ b/integration_tests/sdk/setup_integration.py
@@ -161,9 +161,7 @@ def _setup_external_sqlite_db(path: str):
 
 
 def _setup_postgres_db():
-    print("Installing Aqueduct Postgres Connector")
     _execute_command(["aqueduct", "install", "postgres"])
-    print("Finished installing Postgres Connector")
 
 
 def _setup_relational_data(client: Client, db: RelationalDBIntegration) -> None:
@@ -212,7 +210,6 @@ def setup_data_integrations(client: Client, filter_to: Optional[str] = None) ->
     for integration_name in data_integrations:
         # Only connect to integrations that don't already exist.
         if integration_name not in connected_integrations.keys():
-            print("Fetching integration credentials ...")
             integration_config = _fetch_integration_credentials("data", integration_name)
 
             # Stand up the external integration first.
@@ -220,7 +217,6 @@ def setup_data_integrations(client: Client, filter_to: Optional[str] = None) ->
                 _setup_external_sqlite_db(integration_config["database"])
 
             if integration_config["type"] == ServiceType.POSTGRES:
-                print("Postgres case hit!!")
                 _setup_postgres_db()
 
             client.connect_integration(