Pipe Worker Output Action Names

square · Dec 13, 2024 · f6ee63f · f6ee63f
1 parent 0a219dc
commit f6ee63f
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 6 deletions.
diff --git a/workflow-core/src/commonMain/kotlin/com/squareup/workflow1/Sink.kt b/workflow-core/src/commonMain/kotlin/com/squareup/workflow1/Sink.kt
@@ -85,7 +85,9 @@ internal suspend fun <
 ) {
   suspendCancellableCoroutine<Unit> { continuation ->
     val resumingAction = object : WorkflowAction<PropsT, StateT, OutputT>() {
-      override fun toString(): String = "sendAndAwaitApplication($action)"
+      // Pipe through debugging name to the original action.
+      override val debuggingName: String
+        get() = action.debuggingName
 
       override fun Updater.apply() {
         // Don't execute anything if the caller was cancelled while we were in the queue.

diff --git a/workflow-core/src/commonMain/kotlin/com/squareup/workflow1/WorkerWorkflow.kt b/workflow-core/src/commonMain/kotlin/com/squareup/workflow1/WorkerWorkflow.kt
@@ -89,13 +89,12 @@ internal suspend fun <OutputT> runWorker(
 }
 
 private class EmitWorkerOutputAction<P, S, O>(
-  private val worker: Worker<*>,
-  private val renderKey: String,
+  worker: Worker<*>,
+  renderKey: String,
   private val output: O,
 ) : WorkflowAction<P, S, O>() {
-  override val debuggingName: String
-    get() = CommonKClassTypeNamer.uniqueName(EmitWorkerOutputAction::class) +
-      "(worker=$worker, key=$renderKey)"
+  override val debuggingName: String =
+    "EmitWorkerOutputAction(worker=$worker, key=$renderKey)"
 
   override fun Updater.apply() {
     setOutput(output)