💥 Standalone Activities for Ruby

.gitattributes

@@ -0,0 +1 @@
+CHANGELOG.md merge=union

CHANGELOG.md

@@ -0,0 +1,17 @@
+# Changelog
+
+## [Unreleased]
+
+### Added
+
+- 💥 Standalone Activities: activities that execute independently of any workflow.
+  ```
+	handle = client.start_activity(
+		MyActivity,
+		'some-arg',
+		id: 'my-activity-id',
+		task_queue: 'my-task-queue',
+		start_to_close_timeout: 60
+		)
+	result = handle.result   # blocks until the activity completes
+  ```

README.md

@@ -1092,6 +1092,66 @@ it will raise the error raised in the activity.
 The constructor of the environment has multiple keyword arguments that can be set to affect the activity context for the
 activity.
 
+#### Standalone Activities
+
+Activities can be started directly from a client, outside the context of any workflow. Standalone activities reuse the
+existing `Activity::Definition` class — the same activity code runs whether invoked from a workflow or as a standalone
+activity. They are addressed by `activity_id` (with an optional `activity_run_id` for disambiguating re-runs).
+
+Start a standalone activity:
+
+```ruby
+handle = client.start_activity(
+  MyActivity,
+  'some-arg',
+  id: 'my-activity-id',
+  task_queue: 'my-task-queue',
+  start_to_close_timeout: 60
+)
+result = handle.result   # blocks until the activity completes
+```
+
+Or use the start-and-wait shortcut:
+
+```ruby
+result = client.execute_activity(
+  MyActivity, 'some-arg',
+  id: 'my-activity-id', task_queue: 'my-task-queue', start_to_close_timeout: 60
+)
+```
+
+Get a handle to an existing standalone activity to describe, cancel, terminate, or fetch its result:
+
+```ruby
+handle = client.activity_handle('my-activity-id')
+description = handle.describe       # ActivityExecution::Description
+result = handle.result              # blocks until the activity reaches a terminal state
+handle.cancel('reason for cancel'). # or
+handle.terminate('reason for terminate')
+```
+
+List and count standalone activities (visibility queries):
+
+```ruby
+client.list_activities('ActivityType="MyActivity"').each { |exec| puts exec.activity_id }
+count = client.count_activities('ActivityType="MyActivity"').count
+```
+
+Inside an activity body, `Temporalio::Activity::Context.current.info` exposes whether the activity is standalone
+or workflow-scheduled:
+
+```ruby
+info = Temporalio::Activity::Context.current.info
+if info.in_workflow?
+  # info.workflow_id, info.workflow_run_id, info.workflow_type are set
+else
+  # info.activity_run_id is set; workflow_* fields are nil
+end
+```
+
+Standalone activities require the dev server to enable the SAA feature flags. See the test bootstrap in
+`temporalio/test/test.rb` for the required `--dynamic-config-value` flags.
+
 ### Telemetry
 
 #### Metrics

temporalio/ext/Cargo.toml

@@ -17,9 +17,9 @@ magnus = "0.8"
 parking_lot = "0.12"
 prost = { workspace = true }
 rb-sys = "0.9"
-temporalio-client = { version = "0.3.0", path = "./sdk-core/crates/client" }
-temporalio-common = { version = "0.3.0", path = "./sdk-core/crates/common", features = ["envconfig"] }
-temporalio-sdk-core = { version = "0.3.0", path = "./sdk-core/crates/sdk-core", features = ["ephemeral-server", "otel"] }
+temporalio-client = { version = "0.4.0", path = "./sdk-core/crates/client" }
+temporalio-common = { version = "0.4.0", path = "./sdk-core/crates/common", features = ["envconfig"] }
+temporalio-sdk-core = { version = "0.4.0", path = "./sdk-core/crates/sdk-core", features = ["ephemeral-server", "otel"] }
 tokio = "1.47"
 tokio-stream = "0.1"
 tokio-util = "0.7"

temporalio/ext/src/client_rpc_generated.rs

@@ -1104,6 +1104,14 @@ impl Client {
                     cloud_service,
                     create_connectivity_rule
                 ),
+                "create_custom_role" => rpc_call!(
+                    self,
+                    callback,
+                    call,
+                    CloudService,
+                    cloud_service,
+                    create_custom_role
+                ),
                 "create_namespace" => rpc_call!(
                     self,
                     callback,
@@ -1176,6 +1184,14 @@ impl Client {
                     cloud_service,
                     delete_connectivity_rule
                 ),
+                "delete_custom_role" => rpc_call!(
+                    self,
+                    callback,
+                    call,
+                    CloudService,
+                    cloud_service,
+                    delete_custom_role
+                ),
                 "delete_namespace" => rpc_call!(
                     self,
                     callback,
@@ -1328,6 +1344,22 @@ impl Client {
                     cloud_service,
                     get_current_identity
                 ),
+                "get_custom_role" => rpc_call!(
+                    self,
+                    callback,
+                    call,
+                    CloudService,
+                    cloud_service,
+                    get_custom_role
+                ),
+                "get_custom_roles" => rpc_call!(
+                    self,
+                    callback,
+                    call,
+                    CloudService,
+                    cloud_service,
+                    get_custom_roles
+                ),
                 "get_namespace" => rpc_call!(
                     self,
                     callback,
@@ -1513,6 +1545,14 @@ impl Client {
                     cloud_service,
                     update_api_key
                 ),
+                "update_custom_role" => rpc_call!(
+                    self,
+                    callback,
+                    call,
+                    CloudService,
+                    cloud_service,
+                    update_custom_role
+                ),
                 "update_namespace" => rpc_call!(
                     self,
                     callback,

temporalio/lib/temporalio/activity/definition.rb

@@ -155,6 +155,28 @@ class Info
         # @return [Object, nil] Result hint
         attr_reader :result_hint
 
+        # Resolve an activity argument into a `[name, arg_hints, result_hint]` triple. Used by
+        # `Client#start_activity` to accept any of: a `Definition` subclass, an instance of one,
+        # an `Info`, a `Symbol` activity name, or a `String` activity name. Class/instance/Info
+        # inputs carry their definition's hints; Symbol/String inputs return `nil` hints.
+        #
+        # @param activity [Class<Definition>, Definition, Info, Symbol, String] Activity argument.
+        # @return [Array(String, Array[Object]?, Object?)] name, arg_hints, result_hint.
+        def self._type_and_hints_from_parameter(activity)
+          case activity
+          when String, Symbol
+            [activity.to_s, nil, nil]
+          when Class, Definition, Info
+            # Return or construct an Info -- needed because we want the checks in Info.initialize.
+            info = from_activity(activity)
+            raise ArgumentError, 'Cannot pass dynamic activity to start_activity' unless info.name
+
+            [info.name.to_s, info.arg_hints, info.result_hint]
+          else
+            raise ArgumentError, "#{activity} is not an activity class, instance, info, symbol, or string"
+          end
+        end
+
         # Obtain definition info representing the given activity, which can be a class, instance, or definition info.
         #
         # @param activity [Definition, Class<Definition>, Info] Activity to get info for.

temporalio/lib/temporalio/activity/info.rb

@@ -7,11 +7,13 @@ module Temporalio
   module Activity
     Info = Data.define(
       :activity_id,
+      :activity_run_id,
       :activity_type,
       :attempt,
       :current_attempt_scheduled_time,
       :heartbeat_timeout,
       :local?,
+      :namespace,
       :priority,
       :retry_policy,
       :raw_heartbeat_details,
@@ -31,16 +33,21 @@ module Activity
     #
     # @!attribute activity_id
     #   @return [String] ID for the activity.
+    # @!attribute activity_run_id
+    #   @return [String, nil] Run ID for a standalone activity execution. nil for activities scheduled from a workflow.
     # @!attribute activity_type
     #   @return [String] Type name for the activity.
     # @!attribute attempt
-    #   @return [Integer] Attempt the activity is on.
+    #   @return [Integer] Attempt the activity is on. Attempts start at 1 and increment on each retry.
     # @!attribute current_attempt_scheduled_time
     #   @return [Time] When the current attempt was scheduled.
     # @!attribute heartbeat_timeout
     #   @return [Float, nil] Heartbeat timeout set by the caller.
     # @!attribute local?
     #   @return [Boolean] Whether the activity is a local activity or not.
+    # @!attribute namespace
+    #   @return [String, nil] Namespace this activity is on. Always set, including for standalone activities. Prefer this
+    #     accessor over the deprecated {workflow_namespace}.
     # @!attribute priority
     #   @return [Priority] The priority of this activity.
     # @!attribute retry_policy
@@ -64,17 +71,24 @@ module Activity
     #   @return [String] Task token uniquely identifying this activity. Note, this is a `ASCII-8BIT` encoded string, not
     #     a `UTF-8` encoded string nor a valid UTF-8 string.
     # @!attribute workflow_id
-    #   @return [String] Workflow ID that started this activity.
+    #   @return [String, nil] Workflow ID that started this activity. nil for standalone activities.
     # @!attribute workflow_namespace
-    #   @return [String] Namespace this activity is on.
+    #   @return [String, nil] Namespace this activity is on.
+    #   @deprecated Use {#namespace} instead. The value is identical regardless of whether the activity is
+    #     standalone or scheduled from a workflow.
     # @!attribute workflow_run_id
-    #   @return [String] Workflow run ID that started this activity.
+    #   @return [String, nil] Workflow run ID that started this activity. nil for standalone activities.
     # @!attribute workflow_type
-    #   @return [String] Workflow type name that started this activity.
+    #   @return [String, nil] Workflow type name that started this activity. nil for standalone activities.
     #
     # @note WARNING: This class may have required parameters added to its constructor. Users should not instantiate this
     #   class or it may break in incompatible ways.
     class Info
+      # @return [Boolean] True if this activity was scheduled by a workflow execution; false for standalone activities.
+      def in_workflow?
+        !workflow_id.nil?
+      end
+
       # Convert raw heartbeat details into Ruby types.
       #
       # Note, this live-converts every invocation.