Workflow Import/Export/Delete

transact/build.gradle.kts

@@ -35,6 +35,7 @@ dependencies {
     implementation("com.fasterxml.jackson.core:jackson-databind:2.20.1") // json
     implementation("com.fasterxml.jackson.datatype:jackson-datatype-jsr310:2.20.1")
     implementation("com.cronutils:cron-utils:9.2.1") // cron for scheduled wf
+    implementation("io.netty:netty-all:4.1.130.Final") // netty for websocket
 
     compileOnly("org.jspecify:jspecify:1.0.0")
 

transact/src/main/java/dev/dbos/transact/DBOS.java

@@ -696,6 +696,28 @@ public static void cancelWorkflow(@NonNull String workflowId) {
     return forkWorkflow(workflowId, startStep, new ForkOptions());
   }
 
+  /**
+   * Deletes a workflow from the system. Does not delete child workflows.
+   *
+   * @param workflowId the unique identifier of the workflow to delete. Must not be null.
+   * @throws IllegalArgumentException if workflowId is null
+   */
+  public static void deleteWorkflow(@NonNull String workflowId) {
+    deleteWorkflow(workflowId, false);
+  }
+
+  /**
+   * Deletes a workflow and optionally its child workflows from the system.
+   *
+   * @param workflowId the unique identifier of the workflow to delete. Must not be null.
+   * @param deleteChildren if true, also deletes all child workflows associated with the specified
+   *     workflow; if false, only deletes the specified workflow
+   * @throws IllegalArgumentException if workflowId is null
+   */
+  public static void deleteWorkflow(@NonNull String workflowId, boolean deleteChildren) {
+    executor("deleteWorkflow").deleteWorkflow(workflowId, deleteChildren);
+  }
+
   /**
    * Retrieve a handle to a workflow, given its ID. Note that a handle is always returned, whether
    * the workflow exists or not; getStatus() can be used to tell the difference