Merge pull request #95 from gregwym/greg/shutdown-log

Log shutdown progress for activity and workflow pollers

Author: cj-cb

CHANGELOG.md

@@ -1,5 +1,11 @@
 # Changelog
 
+## 0.1.28
+- Log shutdown progress for activity and workflow pollers
+- Add WorkflowAlreadyCompletingError to the rbi file
+- Validate that a workflow isn't completed before recording commands
+- Ruby 3 compatibility
+
 ## 0.1.21
 - Add workflow id and activity id to workflow and activity logs
 

lib/cadence/activity/poller.rb

@@ -33,7 +33,9 @@ def stop
 
       def wait
         thread.join
+        Cadence.logger.info('Draining activity worker job queue')
         thread_pool.shutdown
+        Cadence.logger.info('Activity poller shutdown gracefully')
       end
 
       private

lib/cadence/version.rb

@@ -1,3 +1,3 @@
 module Cadence
-  VERSION = '0.1.21'.freeze
+  VERSION = '0.1.28'.freeze
 end

lib/cadence/workflow/poller.rb

@@ -29,12 +29,14 @@ def start
 
       def stop
         @shutting_down = true
-        Cadence.logger.info('Shutting down a workflow poller')
+        Cadence.logger.info('Shutting down workflow poller')
       end
 
       def wait
         @thread.join
+        Cadence.logger.info('Draining workflow worker job queue')
         thread_pool.shutdown
+        Cadence.logger.info('Workflow poller shutdown gracefully')
       end
 
       private