chore: Migrate to Obelisk 0.25.0

Author: tomasol

dev-deps.txt

@@ -3,9 +3,9 @@ cargo-expand 1.0.116
 cargo-insta 1.43.2
 cargo-nextest 0.9.103
 just 1.42.4
-obelisk 0.24.2
+obelisk 0.25.0
 pkg-config 0.29.2
-rustc 1.89.0 (29483883e 2025-08-04)
+rustc 1.90.0 (1159e78c4 2025-09-14)
 wasm-tools 1.239.0
 wasmtime 36.0.2
 ldd (GNU libc) 2.40

flake.lock

@@ -1,4 +1,4 @@
 [toolchain]
-channel = "1.89"
+channel = "1.90"
 targets = ["wasm32-unknown-unknown", "wasm32-wasip2"]
 components = ["rustfmt", "clippy", "rust-src", "rust-analyzer", "cargo"]

rust-toolchain.toml

@@ -1,7 +1,9 @@
-package obelisk:types@2.0.0;
+package obelisk:types@3.0.0;
 
+@since(version = 3.0.0)
 interface time {
 
+    @since(version = 3.0.0)
     variant duration {
         milliseconds(u64),
         seconds(u64),
@@ -12,47 +14,54 @@ interface time {
 
     /// A time and date in seconds plus nanoseconds.
     // Extracted from wasi:clocks@0.2.0 to avoid dependency on wasi:io
+    @since(version = 3.0.0)
     record datetime {
         seconds: u64,
         nanoseconds: u32,
     }
 
+    @since(version = 3.0.0)
     variant schedule-at {
         now,
         at(datetime),
         in(duration),
     }
 }
 
+@since(version = 3.0.0)
 interface execution {
 
-    resource join-set-id {
+    /// Join set resouce.
+    @since(version = 3.0.0)
+    resource join-set {
+        @since(version = 3.0.0)
         id: func() -> string;
     }
 
+    @since(version = 3.0.0)
     record execution-id {
         id: string,
     }
 
+    @since(version = 3.0.0)
     record delay-id {
         id: string,
     }
 
-    record execution-failed {
-        execution-id: execution-id,
-    }
-
+    @since(version = 3.0.0)
     record function {
         // `namespace:pkg_name/ifc_name` or `namespace:pkg_name/ifc_name@version`
         interface-name: string,
         function-name: string,
     }
 
+    @since(version = 3.0.0)
     variant response-id {
         execution-id(execution-id),
         delay-id(delay-id),
     }
 
+    @since(version = 3.0.0)
     record function-mismatch {
         /// Workflow requested function
         specified-function: function,
@@ -62,20 +71,18 @@ interface execution {
     }
 
     /// Error that is thrown by `-await-next` extension functions.
+    @since(version = 3.0.0)
     variant await-next-extension-error {
-        /// Execution response was awaited and marked as processed, but it finished with an error.
-        execution-failed(execution-failed),
         /// All submitted requests and their responses of specified function and join set were already processed.
         all-processed,
         /// Execution response was awaited and marked as processed, but it belongs to a different function.
         /// This can happen when join set contains responses of multiple functions or delay requests.
         function-mismatch(function-mismatch),
     }
 
-    /// Error that is thrown by `-get` extension functions.
+    /// Error variants that may occur when calling `-get` extension functions.
+    @since(version = 3.0.0)
     variant get-extension-error {
-        /// Execution is found in processed responses, but it finished with an error.
-        execution-failed(execution-failed),
         /// Execution is found in processed responses, but it belongs to a different function.
         /// This can happen when join set contains responses of multiple functions.
         function-mismatch(function-mismatch),
@@ -85,6 +92,14 @@ interface execution {
         not-found-in-processed-responses,
     }
 
+    /// Error variants that may occur when calling `-invoke` extension functions.
+    @since(version = 3.0.0)
+    variant invoke-extension-error {
+        invalid-name(string),
+    }
+
+    /// Error variants that may occur when calling `-stub` extension functions.
+    @since(version = 3.0.0)
     variant stub-error {
         /// Conflict can happen when a second writer attempts to stub a value, while the
         /// value is not equal to the already stubbed value.

…deps/obelisk_types@2.0.0/types@2.0.0.wit …o/wit/deps/obelisk_types@3.0.0/types.witworkflow/deployer-workflow/impl-flyio/wit/deps/obelisk_types@2.0.0/types@2.0.0.wit renamed to workflow/deployer-workflow/impl-flyio/wit/deps/obelisk_types@3.0.0/types.wit workflow/deployer-workflow/impl-flyio/wit/deps/obelisk_types@2.0.0/types@2.0.0.wit renamed to workflow/deployer-workflow/impl-flyio/wit/deps/obelisk_types@3.0.0/types.wit

@@ -1,10 +1,12 @@
-package obelisk:workflow@2.0.0;
+package obelisk:workflow@3.0.0;
 
+@since(version = 3.0.0)
 interface workflow-support {
-    use obelisk:types/time@2.0.0.{schedule-at};
-    use obelisk:types/execution@2.0.0.{join-set-id, delay-id, execution-id, response-id};
+    use obelisk:types/time@3.0.0.{schedule-at, datetime};
+    use obelisk:types/execution@3.0.0.{join-set, delay-id, execution-id, response-id};
 
     /// The closing strategy of a join set. Join sets are closed when execution finishes.
+    @since(version = 3.0.0)
     enum closing-strategy {
         /// All submitted child execution requests that were not awaited by the workflow are awaited during join set close.
         /// Delay requests are not awaited.
@@ -14,42 +16,60 @@ interface workflow-support {
         // TODO: Implement cancel
     }
 
+    /// Error variants that may occur on named join set creation.
+    @since(version = 3.0.0)
     variant join-set-create-error {
         conflict,
         invalid-name(string),
     }
 
-
     /// Returns a random u64 in the range [min, max).
+    @since(version = 3.0.0)
     random-u64: func(min: u64, max-exclusive: u64) -> u64;
     /// Returns a random u64 in the range [min, max].
+    @since(version = 3.0.0)
     random-u64-inclusive: func(min: u64, max-inclusive: u64) -> u64;
 
     /// Returns a random string with a length in the range [min_length, max_length).
     /// The string consists only of alphanumeric characters (lowercase and uppercase letters, digits).
+    @since(version = 3.0.0)
     random-string: func(min-length: u16, max-length-exclusive: u16) -> string;
 
-    /// Block execution for given time.
-    sleep: func(schedule-at: schedule-at);
+    /// Block execution for given time, return `schedule-at` resolved to time when the execution is scheduled.
+    @since(version = 3.0.0)
+    sleep: func(schedule-at: schedule-at) -> datetime;
 
     /// Submit a delay request to the join set. The delay can be later polled using `join-next`.
-    submit-delay: func(join-set-id: borrow<join-set-id>, timeout: schedule-at) -> delay-id;
+    @since(version = 3.0.0)
+    submit-delay: func(join-set: borrow<join-set>, timeout: schedule-at) -> delay-id;
 
     /// Create a new completing join set.
-    new-join-set-named: func(name: string, closing-strategy: closing-strategy) -> result<join-set-id, join-set-create-error>;
+    @since(version = 3.0.0)
+    new-join-set-named: func(name: string, closing-strategy: closing-strategy) -> result<join-set, join-set-create-error>;
 
     /// Create a new completing join set with a generated name.
-    new-join-set-generated: func(closing-strategy: closing-strategy) -> join-set-id;
+    @since(version = 3.0.0)
+    new-join-set-generated: func(closing-strategy: closing-strategy) -> join-set;
 
+    /// Error variants that may occur when calling `join-next` function.
+    @since(version = 3.0.0)
     variant join-next-error {
         /// All submitted requests and their responses were already processed.
         all-processed,
     }
+
+    /// Explicitly close join set. All executions that were submitted and not awaited,
+    /// in other words executions with unprocessed responses, will be either
+    /// awaited or cancelled based on `closing-strategy`.
+    /// Extension function `-get` can be used to lookup the execution result.
+    @since(version = 3.0.0)
+    close: func(join-set: join-set);
+
     /// Block the workflow execution until next response associated with the join set arrives.
     /// The response is marked as processed.
     /// Child execution result can be obtained using `-get` extension function using the
     /// returned execution ID.
-    /// Return `none` if the join set has all requests matched with responses.
-    join-next: func(join-set-id: borrow<join-set-id>) ->
-        result<response-id, join-next-error>;
+    /// Return `join-next-error::all-processed` if the join set has all requests matched with responses.
+    @since(version = 3.0.0)
+    join-next: func(join-set: borrow<join-set>) -> result<response-id, join-next-error>;
 }

…orkflow@2.0.0/workflow-support@2.0.0.wit …lisk_workflow@3.0.0/workflow-support.witworkflow/deployer-workflow/impl-flyio/wit/deps/obelisk_workflow@2.0.0/workflow-support@2.0.0.wit renamed to workflow/deployer-workflow/impl-flyio/wit/deps/obelisk_workflow@3.0.0/workflow-support.wit workflow/deployer-workflow/impl-flyio/wit/deps/obelisk_workflow@2.0.0/workflow-support@2.0.0.wit renamed to workflow/deployer-workflow/impl-flyio/wit/deps/obelisk_workflow@3.0.0/workflow-support.wit

@@ -6,5 +6,5 @@ world any {
     import obelisk-flyio:activity-fly-http/apps@1.0.0-beta;
     import obelisk-flyio:activity-fly-http/machines@1.0.0-beta;
     import obelisk-flyio:activity-fly-http/volumes@1.0.0-beta;
-    import obelisk:workflow/workflow-support@2.0.0;
+    import obelisk:workflow/workflow-support@3.0.0;
 }

workflow/deployer-workflow/impl-flyio/wit/impl.wit

@@ -63,11 +63,13 @@ interface workflow {
         cleanup-ok(app-init-modify-error),
         cleanup-failed(app-cleanup-failed),
         cleanup-skipped(app-init-modify-error),
+        execution-failure,
     }
 
     variant serve-error {
         vm-start-error(string),
         healthcheck-error(string),
+        execution-failure,
     }
 
     /// Chcek whether the app_name exists. If it does, return app-name-conflict.