review fixes, added test

Author: THardy98

README.md

@@ -28,10 +28,10 @@ Prerequisites:
 * [context_propagation](context_propagation) - Use interceptors to propagate thread/fiber local data from clients
   through workflows/activities.
 * [message_passing_simple](message_passing_simple) - Simple workflow that accepts signals, queries, and updates.
+* [polling/infrequent](polling/infrequent) - Implement an infrequent polling mechanism using Temporal's automatic Activity Retry feature.
 * [rails_app](rails_app) - Basic Rails API application using Temporal workflows and activities.
 * [sorbet_generic](sorbet_generic) - Proof of concept of how to do _advanced_ Sorbet typing with the SDK.
 * [worker_specific_task_queues](worker_specific_task_queues) - Use a unique Task Queue for each Worker to run a sequence of Activities on the same Worker.
-* [polling/infrequent](polling/infrequent/) - implement an infrequent polling mechanism using Temporal's automatic Activity Retry feature
 
 ## Development
 

polling/infrequent/greeting_workflow.rb

@@ -2,7 +2,6 @@
 
 require 'temporalio/workflow'
 require_relative 'compose_greeting_activity'
-require_relative 'test_service'
 
 module Polling
   module Infrequent

test/polling/infrequent_polling_test.rb

@@ -0,0 +1,42 @@
+# frozen_string_literal: true
+
+require 'test'
+require 'securerandom'
+require 'temporalio/testing'
+require 'temporalio/worker'
+require 'polling/infrequent/greeting_workflow'
+require 'polling/infrequent/compose_greeting_activity'
+require 'polling/infrequent/test_service'
+
+module Polling
+  class InfrequentPollingTest < Test
+    def test_workflow_completes_after_polling
+      task_queue = "tq-#{SecureRandom.uuid}"
+
+      Temporalio::Testing::WorkflowEnvironment.start_time_skipping do |env|
+        worker = Temporalio::Worker.new(
+          client: env.client,
+          task_queue: task_queue,
+          activities: [Polling::Infrequent::ComposeGreetingActivity],
+          workflows: [Polling::Infrequent::GreetingWorkflow]
+        )
+
+        handle = env.client.start_workflow(
+          Polling::Infrequent::GreetingWorkflow,
+          'Temporal',
+          id: "wf-#{SecureRandom.uuid}",
+          task_queue: task_queue
+        )
+
+        worker.run do
+          # Advance time forward to allow for the 4 retries (4 * 60s) plus a buffer
+          env.sleep(241)
+
+          # Wait for the workflow to complete and assert its result
+          result = handle.result
+          assert_equal('Hello, Temporal!', result)
+        end
+      end
+    end
+  end
+end