diff --git a/app/workers/clean_up_worker.rb b/app/workers/clean_up_worker.rb
deleted file mode 100644
index e126aab01..000000000
--- a/app/workers/clean_up_worker.rb
+++ /dev/null
@@ -1,8 +0,0 @@
-class CleanUpWorker
-  include Sidekiq::Worker
-
-  def perform
-    CkbTransaction.tx_pending.where("created_at < ?", 1.day.ago).destroy_all
-    CkbTransaction.tx_rejected.where("created_at < ?", 3.months.ago).destroy_all
-  end
-end
diff --git a/app/workers/pool_transaction_check_worker.rb b/app/workers/pool_transaction_check_worker.rb
index 885c17163..d23eeef0d 100644
--- a/app/workers/pool_transaction_check_worker.rb
+++ b/app/workers/pool_transaction_check_worker.rb
@@ -10,6 +10,10 @@ def perform
       response_string = CkbSync::Api.instance.directly_single_call_rpc method: "get_transaction",
                                                                        params: [tx.tx_hash]
       reason = response_string["result"]["tx_status"]
+      if reason["status"] == "committed" && CkbTransaction.where(tx_hash: tx.tx_hash, tx_status: :committed).exists?
+        tx.destroy
+      end
+
       if reason["status"] == "rejected"
         ApplicationRecord.transaction do
           tx.update! tx_status: "rejected"