diff --git a/.github/workflows/cancel-duplicates.yml b/.github/workflows/cancel-duplicates.yml
deleted file mode 100644
index c737dff89012f..0000000000000
--- a/.github/workflows/cancel-duplicates.yml
+++ /dev/null
@@ -1,62 +0,0 @@
-#
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements.  See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership.  The ASF licenses this file
-# to you under the Apache License, Version 2.0 (the
-# "License"); you may not use this file except in compliance
-# with the License.  You may obtain a copy of the License at
-#
-#   http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing,
-# software distributed under the License is distributed on an
-# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-# KIND, either express or implied.  See the License for the
-# specific language governing permissions and limitations
-# under the License.
-#
-
-name: Cancelling Duplicates
-on:
-  workflow_run:
-    workflows: 
-      - 'CI - Build - MacOS'
-      - 'CI - CPP, Python Tests'
-      - 'CI - Go Functions style check'
-      - 'CI - Go Functions Tests'
-      - 'CI - Integration - Backwards Compatibility'
-      - 'CI - Integration - Cli'
-      - 'CI - Integration - Function State'
-      - 'CI - Integration - Messaging'
-      - 'CI - Integration - Process'
-      - 'CI - Integration - Schema'
-      - 'CI - Integration - Sql'
-      - 'CI - Integration - Standalone'
-      - 'CI - Integration - Thread'
-      - 'CI - Integration - Tiered FileSystem'
-      - 'CI - Integration - Tiered JCloud'
-      - 'CI - Integration - Transaction'
-      - 'CI - Misc'
-      - 'CI - Pulsar Website build'
-      - 'CI - Shade - Test'
-      - 'CI - Unit - Brokers - Broker Group 1'
-      - 'CI - Unit - Brokers - Broker Group 2'
-      - 'CI - Unit - Brokers - Client Api'
-      - 'CI - Unit - Brokers - Client Impl'
-      - 'CI - Unit - Brokers - Other'
-      - 'CI - Unit - Proxy'
-      - 'CI - Unit'
-    types: ['requested']
-
-jobs:
-  cancel-duplicate-workflow-runs:
-    name: "Cancel duplicate workflow runs"
-    runs-on: ubuntu-latest
-    steps:
-      - uses: potiuk/cancel-workflow-runs@953e057dc81d3458935a18d1184c386b0f6b5738 # @master
-        name: "Cancel duplicate workflow runs"
-        with:
-          cancelMode: allDuplicates
-          token: ${{ secrets.GITHUB_TOKEN }}
-          sourceRunId: ${{ github.event.workflow_run.id }}
diff --git a/.github/workflows/ci-build-macos.yaml b/.github/workflows/ci-build-macos.yaml
index a7dd482992060..8cc5a33855ca9 100644
--- a/.github/workflows/ci-build-macos.yaml
+++ b/.github/workflows/ci-build-macos.yaml
@@ -39,6 +39,11 @@ jobs:
     timeout-minutes: 120
 
     steps:
+      - name: cancel previous runs
+        uses: apache/airflow-cancel-workflow-runs@953e057dc81d3458935a18d1184c386b0f6b5738
+        with:
+          token: ${{ secrets.GITHUB_TOKEN }}
+
       - name: checkout
         uses: actions/checkout@v2
         with:
diff --git a/.github/workflows/ci-cpp.yaml b/.github/workflows/ci-cpp.yaml
index d4991e97207d0..a9d13b4f42185 100644
--- a/.github/workflows/ci-cpp.yaml
+++ b/.github/workflows/ci-cpp.yaml
@@ -37,6 +37,11 @@ jobs:
     timeout-minutes: 120
 
     steps:
+      - name: cancel previous runs
+        uses: apache/airflow-cancel-workflow-runs@953e057dc81d3458935a18d1184c386b0f6b5738
+        with:
+          token: ${{ secrets.GITHUB_TOKEN }}
+
       - name: checkout
         uses: actions/checkout@v2
         with:
diff --git a/.github/workflows/ci-go-functions-style.yaml b/.github/workflows/ci-go-functions-style.yaml
index 80d7e517eeba4..710c2fdbdf318 100644
--- a/.github/workflows/ci-go-functions-style.yaml
+++ b/.github/workflows/ci-go-functions-style.yaml
@@ -45,6 +45,11 @@ jobs:
         go-version: [1.11, 1.12, 1.13, 1.14]
 
     steps:
+      - name: cancel previous runs
+        uses: apache/airflow-cancel-workflow-runs@953e057dc81d3458935a18d1184c386b0f6b5738
+        with:
+          token: ${{ secrets.GITHUB_TOKEN }}
+
       - name: Check out code into the Go module directory
         uses: actions/checkout@v2
         with:
diff --git a/.github/workflows/ci-go-functions-test.yaml b/.github/workflows/ci-go-functions-test.yaml
index fa7543b4b8404..552eabcc19caa 100644
--- a/.github/workflows/ci-go-functions-test.yaml
+++ b/.github/workflows/ci-go-functions-test.yaml
@@ -47,6 +47,11 @@ jobs:
     timeout-minutes: 120
 
     steps:
+      - name: cancel previous runs
+        uses: apache/airflow-cancel-workflow-runs@953e057dc81d3458935a18d1184c386b0f6b5738
+        with:
+          token: ${{ secrets.GITHUB_TOKEN }}
+
       - name: Check out code into the Go module directory
         uses: actions/checkout@v2
         with:
diff --git a/.github/workflows/ci-integration-backwards-compatibility.yaml b/.github/workflows/ci-integration-backwards-compatibility.yaml
index b65c136734ad0..440e2a69e55ec 100644
--- a/.github/workflows/ci-integration-backwards-compatibility.yaml
+++ b/.github/workflows/ci-integration-backwards-compatibility.yaml
@@ -37,6 +37,11 @@ jobs:
     timeout-minutes: 120
 
     steps:
+      - name: cancel previous runs
+        uses: apache/airflow-cancel-workflow-runs@953e057dc81d3458935a18d1184c386b0f6b5738
+        with:
+          token: ${{ secrets.GITHUB_TOKEN }}
+
       - name: checkout
         uses: actions/checkout@v2
         with:
diff --git a/.github/workflows/ci-integration-cli.yaml b/.github/workflows/ci-integration-cli.yaml
index a1e0b451ba284..b7d22d584183c 100644
--- a/.github/workflows/ci-integration-cli.yaml
+++ b/.github/workflows/ci-integration-cli.yaml
@@ -37,6 +37,11 @@ jobs:
     timeout-minutes: 120
 
     steps:
+      - name: cancel previous runs
+        uses: apache/airflow-cancel-workflow-runs@953e057dc81d3458935a18d1184c386b0f6b5738
+        with:
+          token: ${{ secrets.GITHUB_TOKEN }}
+
       - name: checkout
         uses: actions/checkout@v2
         with:
diff --git a/.github/workflows/ci-integration-function-state.yaml b/.github/workflows/ci-integration-function-state.yaml
index 77df3fd321c14..f007e2a8ef153 100644
--- a/.github/workflows/ci-integration-function-state.yaml
+++ b/.github/workflows/ci-integration-function-state.yaml
@@ -37,6 +37,11 @@ jobs:
     timeout-minutes: 120
 
     steps:
+      - name: cancel previous runs
+        uses: apache/airflow-cancel-workflow-runs@953e057dc81d3458935a18d1184c386b0f6b5738
+        with:
+          token: ${{ secrets.GITHUB_TOKEN }}
+
       - name: checkout
         uses: actions/checkout@v2
         with:
diff --git a/.github/workflows/ci-integration-messaging.yaml b/.github/workflows/ci-integration-messaging.yaml
index 2c3f299edf07a..bf67b18d0f7e9 100644
--- a/.github/workflows/ci-integration-messaging.yaml
+++ b/.github/workflows/ci-integration-messaging.yaml
@@ -37,6 +37,11 @@ jobs:
     timeout-minutes: 120
 
     steps:
+      - name: cancel previous runs
+        uses: apache/airflow-cancel-workflow-runs@953e057dc81d3458935a18d1184c386b0f6b5738
+        with:
+          token: ${{ secrets.GITHUB_TOKEN }}
+
       - name: checkout
         uses: actions/checkout@v2
         with:
diff --git a/.github/workflows/ci-integration-process.yaml b/.github/workflows/ci-integration-process.yaml
index 783c963e4be9b..e01b5e59e5edd 100644
--- a/.github/workflows/ci-integration-process.yaml
+++ b/.github/workflows/ci-integration-process.yaml
@@ -32,11 +32,15 @@ env:
 jobs:
 
   process:
-    name:
     runs-on: ubuntu-latest
     timeout-minutes: 120
 
     steps:
+      - name: cancel previous runs
+        uses: apache/airflow-cancel-workflow-runs@953e057dc81d3458935a18d1184c386b0f6b5738
+        with:
+          token: ${{ secrets.GITHUB_TOKEN }}
+
       - name: checkout
         uses: actions/checkout@v2
         with:
diff --git a/.github/workflows/ci-integration-schema.yaml b/.github/workflows/ci-integration-schema.yaml
index 412e972d7937c..339f9a6ac0e20 100644
--- a/.github/workflows/ci-integration-schema.yaml
+++ b/.github/workflows/ci-integration-schema.yaml
@@ -32,11 +32,15 @@ env:
 jobs:
 
   schema:
-    name:
     runs-on: ubuntu-latest
     timeout-minutes: 120
 
     steps:
+      - name: cancel previous runs
+        uses: apache/airflow-cancel-workflow-runs@953e057dc81d3458935a18d1184c386b0f6b5738
+        with:
+          token: ${{ secrets.GITHUB_TOKEN }}
+
       - name: checkout
         uses: actions/checkout@v2
         with:
diff --git a/.github/workflows/ci-integration-sql.yaml b/.github/workflows/ci-integration-sql.yaml
index a394248ed3fef..b88ea9f7e3078 100644
--- a/.github/workflows/ci-integration-sql.yaml
+++ b/.github/workflows/ci-integration-sql.yaml
@@ -32,11 +32,15 @@ env:
 jobs:
 
   sql:
-    name:
     runs-on: ubuntu-latest
     timeout-minutes: 120
 
     steps:
+      - name: cancel previous runs
+        uses: apache/airflow-cancel-workflow-runs@953e057dc81d3458935a18d1184c386b0f6b5738
+        with:
+          token: ${{ secrets.GITHUB_TOKEN }}
+
       - name: checkout
         uses: actions/checkout@v2
         with:
diff --git a/.github/workflows/ci-integration-standalone.yaml b/.github/workflows/ci-integration-standalone.yaml
index 5f44a15b86e4a..5405461cd89d8 100644
--- a/.github/workflows/ci-integration-standalone.yaml
+++ b/.github/workflows/ci-integration-standalone.yaml
@@ -32,11 +32,15 @@ env:
 jobs:
 
   standalone:
-    name:
     runs-on: ubuntu-latest
     timeout-minutes: 120
 
     steps:
+      - name: cancel previous runs
+        uses: apache/airflow-cancel-workflow-runs@953e057dc81d3458935a18d1184c386b0f6b5738
+        with:
+          token: ${{ secrets.GITHUB_TOKEN }}
+
       - name: checkout
         uses: actions/checkout@v2
         with:
diff --git a/.github/workflows/ci-integration-thread.yaml b/.github/workflows/ci-integration-thread.yaml
index 4f2ad19a39093..326555b6e289b 100644
--- a/.github/workflows/ci-integration-thread.yaml
+++ b/.github/workflows/ci-integration-thread.yaml
@@ -32,11 +32,15 @@ env:
 jobs:
 
   thread:
-    name:
     runs-on: ubuntu-latest
     timeout-minutes: 120
 
     steps:
+      - name: cancel previous runs
+        uses: apache/airflow-cancel-workflow-runs@953e057dc81d3458935a18d1184c386b0f6b5738
+        with:
+          token: ${{ secrets.GITHUB_TOKEN }}
+
       - name: checkout
         uses: actions/checkout@v2
         with:
diff --git a/.github/workflows/ci-integration-tiered-filesystem.yaml b/.github/workflows/ci-integration-tiered-filesystem.yaml
index 4fb4d296ca64b..9f596ae3a42dd 100644
--- a/.github/workflows/ci-integration-tiered-filesystem.yaml
+++ b/.github/workflows/ci-integration-tiered-filesystem.yaml
@@ -32,11 +32,15 @@ env:
 jobs:
 
   tiered-filesystem:
-    name:
     runs-on: ubuntu-latest
     timeout-minutes: 120
 
     steps:
+      - name: cancel previous runs
+        uses: apache/airflow-cancel-workflow-runs@953e057dc81d3458935a18d1184c386b0f6b5738
+        with:
+          token: ${{ secrets.GITHUB_TOKEN }}
+
       - name: checkout
         uses: actions/checkout@v2
         with:
diff --git a/.github/workflows/ci-integration-tiered-jcloud.yaml b/.github/workflows/ci-integration-tiered-jcloud.yaml
index 160aaa55c4d73..b8695e30a79e3 100644
--- a/.github/workflows/ci-integration-tiered-jcloud.yaml
+++ b/.github/workflows/ci-integration-tiered-jcloud.yaml
@@ -32,11 +32,15 @@ env:
 jobs:
 
   tiered-jcloud:
-    name:
     runs-on: ubuntu-latest
     timeout-minutes: 120
 
     steps:
+      - name: cancel previous runs
+        uses: apache/airflow-cancel-workflow-runs@953e057dc81d3458935a18d1184c386b0f6b5738
+        with:
+          token: ${{ secrets.GITHUB_TOKEN }}
+
       - name: checkout
         uses: actions/checkout@v2
         with:
diff --git a/.github/workflows/ci-integration-transaction.yaml b/.github/workflows/ci-integration-transaction.yaml
index 4fe08c8bac440..353cc32cddf1c 100644
--- a/.github/workflows/ci-integration-transaction.yaml
+++ b/.github/workflows/ci-integration-transaction.yaml
@@ -32,11 +32,15 @@ env:
 jobs:
 
   transaction:
-    name:
     runs-on: ubuntu-latest
     timeout-minutes: 120
 
     steps:
+      - name: cancel previous runs
+        uses: apache/airflow-cancel-workflow-runs@953e057dc81d3458935a18d1184c386b0f6b5738
+        with:
+          token: ${{ secrets.GITHUB_TOKEN }}
+
       - name: checkout
         uses: actions/checkout@v2
         with:
diff --git a/.github/workflows/ci-license.yaml b/.github/workflows/ci-license.yaml
index 1e27643b46348..06331ee1eb06b 100644
--- a/.github/workflows/ci-license.yaml
+++ b/.github/workflows/ci-license.yaml
@@ -37,6 +37,11 @@ jobs:
     timeout-minutes: 60
 
     steps:
+      - name: cancel previous runs
+        uses: apache/airflow-cancel-workflow-runs@953e057dc81d3458935a18d1184c386b0f6b5738
+        with:
+          token: ${{ secrets.GITHUB_TOKEN }}
+
       - name: checkout
         uses: actions/checkout@v2
         with:
diff --git a/.github/workflows/ci-pulsar-website-build.yaml b/.github/workflows/ci-pulsar-website-build.yaml
index 388c2c4593ed0..d2b10264b7967 100644
--- a/.github/workflows/ci-pulsar-website-build.yaml
+++ b/.github/workflows/ci-pulsar-website-build.yaml
@@ -31,6 +31,11 @@ jobs:
     runs-on: ubuntu-latest
     timeout-minutes: 120
     steps:
+      - name: cancel previous runs
+        uses: apache/airflow-cancel-workflow-runs@953e057dc81d3458935a18d1184c386b0f6b5738
+        with:
+          token: ${{ secrets.GITHUB_TOKEN }}
+
       - name: checkout
         uses: actions/checkout@v2
 
diff --git a/.github/workflows/ci-shade-test.yaml b/.github/workflows/ci-shade-test.yaml
index ddbf63977decf..9552d4f2b677e 100644
--- a/.github/workflows/ci-shade-test.yaml
+++ b/.github/workflows/ci-shade-test.yaml
@@ -37,6 +37,11 @@ jobs:
     timeout-minutes: 120
 
     steps:
+      - name: cancel previous runs
+        uses: apache/airflow-cancel-workflow-runs@953e057dc81d3458935a18d1184c386b0f6b5738
+        with:
+          token: ${{ secrets.GITHUB_TOKEN }}
+
       - name: checkout
         uses: actions/checkout@v2
         with:
diff --git a/.github/workflows/ci-unit-broker-broker-gp1.yaml b/.github/workflows/ci-unit-broker-broker-gp1.yaml
index aa960a0d05a4e..94f456be070b4 100644
--- a/.github/workflows/ci-unit-broker-broker-gp1.yaml
+++ b/.github/workflows/ci-unit-broker-broker-gp1.yaml
@@ -39,6 +39,11 @@ jobs:
     timeout-minutes: 120
 
     steps:
+      - name: cancel previous runs
+        uses: apache/airflow-cancel-workflow-runs@953e057dc81d3458935a18d1184c386b0f6b5738
+        with:
+          token: ${{ secrets.GITHUB_TOKEN }}
+
       - name: checkout
         uses: actions/checkout@v2
         with:
diff --git a/.github/workflows/ci-unit-broker-broker-gp2.yaml b/.github/workflows/ci-unit-broker-broker-gp2.yaml
index 284924cde39ed..250d64ad30bc2 100644
--- a/.github/workflows/ci-unit-broker-broker-gp2.yaml
+++ b/.github/workflows/ci-unit-broker-broker-gp2.yaml
@@ -39,6 +39,11 @@ jobs:
     timeout-minutes: 120
 
     steps:
+      - name: cancel previous runs
+        uses: apache/airflow-cancel-workflow-runs@953e057dc81d3458935a18d1184c386b0f6b5738
+        with:
+          token: ${{ secrets.GITHUB_TOKEN }}
+
       - name: checkout
         uses: actions/checkout@v2
         with:
diff --git a/.github/workflows/ci-unit-broker-client-api.yaml b/.github/workflows/ci-unit-broker-client-api.yaml
index 9e8512c1ae7ab..7f6e1a9d1ce25 100644
--- a/.github/workflows/ci-unit-broker-client-api.yaml
+++ b/.github/workflows/ci-unit-broker-client-api.yaml
@@ -39,6 +39,11 @@ jobs:
     timeout-minutes: 120
 
     steps:
+      - name: cancel previous runs
+        uses: apache/airflow-cancel-workflow-runs@953e057dc81d3458935a18d1184c386b0f6b5738
+        with:
+          token: ${{ secrets.GITHUB_TOKEN }}
+
       - name: checkout
         uses: actions/checkout@v2
         with:
diff --git a/.github/workflows/ci-unit-broker-client-impl.yaml b/.github/workflows/ci-unit-broker-client-impl.yaml
index 989be8615a694..4833fc477dc1d 100644
--- a/.github/workflows/ci-unit-broker-client-impl.yaml
+++ b/.github/workflows/ci-unit-broker-client-impl.yaml
@@ -39,6 +39,11 @@ jobs:
     timeout-minutes: 120
 
     steps:
+      - name: cancel previous runs
+        uses: apache/airflow-cancel-workflow-runs@953e057dc81d3458935a18d1184c386b0f6b5738
+        with:
+          token: ${{ secrets.GITHUB_TOKEN }}
+
       - name: checkout
         uses: actions/checkout@v2
         with:
diff --git a/.github/workflows/ci-unit-broker-other.yaml b/.github/workflows/ci-unit-broker-other.yaml
index ac3d53d3a8287..e0c8e64c5370d 100644
--- a/.github/workflows/ci-unit-broker-other.yaml
+++ b/.github/workflows/ci-unit-broker-other.yaml
@@ -39,6 +39,11 @@ jobs:
     timeout-minutes: 120
 
     steps:
+      - name: cancel previous runs
+        uses: apache/airflow-cancel-workflow-runs@953e057dc81d3458935a18d1184c386b0f6b5738
+        with:
+          token: ${{ secrets.GITHUB_TOKEN }}
+
       - name: checkout
         uses: actions/checkout@v2
         with:
diff --git a/.github/workflows/ci-unit-proxy.yaml b/.github/workflows/ci-unit-proxy.yaml
index 193baeaee4140..359700f97afe5 100644
--- a/.github/workflows/ci-unit-proxy.yaml
+++ b/.github/workflows/ci-unit-proxy.yaml
@@ -39,6 +39,11 @@ jobs:
     timeout-minutes: 120
 
     steps:
+      - name: cancel previous runs
+        uses: apache/airflow-cancel-workflow-runs@953e057dc81d3458935a18d1184c386b0f6b5738
+        with:
+          token: ${{ secrets.GITHUB_TOKEN }}
+
       - name: checkout
         uses: actions/checkout@v2
         with:
diff --git a/.github/workflows/ci-unit.yaml b/.github/workflows/ci-unit.yaml
index 886bf77488828..ee321e3790997 100644
--- a/.github/workflows/ci-unit.yaml
+++ b/.github/workflows/ci-unit.yaml
@@ -39,6 +39,11 @@ jobs:
     timeout-minutes: 120
 
     steps:
+      - name: cancel previous runs
+        uses: apache/airflow-cancel-workflow-runs@953e057dc81d3458935a18d1184c386b0f6b5738
+        with:
+          token: ${{ secrets.GITHUB_TOKEN }}
+
       - name: checkout
         uses: actions/checkout@v2
         with: