[Compass-ci] Re: [PATCH compass-ci] /src/extract-stats: rescue when the task-queue disconnect

8 Mar 2021

On Mon, Mar 08, 2021 at 03:16:39PM +0800, Luan Shengde wrote:
...
...

--- a/src/extract-stats/stats_worker.cr
+++ b/src/extract-stats/stats_worker.cr
@@ -26,9 +26,12 @@ class StatsWorker
          @tq.delete_task(queue_path + "/in_process", "#{job_id}")
        end
      rescue e
-        STDERR.puts e.message
+        error_message = e.message
+        STDERR.puts error_message
no need to add a mid-variable, just use:
       STDERR.puts e.message
ok

Thanks,
Weitao
...
...
+
        # incase of many error message when task-queue, ES does not work
        sleep(10)
+        @tq = TaskQueueAPI.new if error_message && error_message.includes?("3060': Connection refused")
      end
    end
  end
--
2.23.0

    

Lu Weitao