- PS

Author: dandavison

service/history/chasm_engine.go

@@ -367,8 +367,6 @@ func (e *ChasmEngine) predicateSatisfied(
 	executionLease api.WorkflowLease,
 	predicateFn func(chasm.Context, chasm.Component) (bool, error),
 ) ([]byte, error) {
-	fmt.Println("🔎 checkPredicate")
-
 	chasmTree, ok := executionLease.GetMutableState().ChasmTree().(*chasm.Node)
 	if !ok {
 		return nil, serviceerror.NewInternalf(
@@ -401,15 +399,13 @@ func (e *ChasmEngine) predicateSatisfied(
 		return nil, err
 	}
 	if !satisfied {
-		fmt.Println("    🟠 checkPredicate: predicate not satisfied")
 		return nil, nil
 	}
 
 	newRef, err := chasmContext.Ref(component)
 	if err != nil {
 		return nil, err
 	}
-	fmt.Println("    🟢 checkPredicate: predicate satisfied")
 	return newRef, nil
 }
 

service/history/chasm_notifier.go

@@ -4,7 +4,6 @@
 package history
 
 import (
-	"fmt"
 	"sync"
 
 	"go.temporal.io/server/chasm"
@@ -43,14 +42,12 @@ func (n *ChasmNotifier) Notify(key chasm.EntityKey) {
 
 // Subscribe returns a channel that will be closed to indicate that there is a notification relating to the execution.
 func (n *ChasmNotifier) Subscribe(key chasm.EntityKey) (<-chan struct{}, error) {
-	fmt.Println("🟠 Subscribe")
 	var ch chan struct{}
 	var ok bool
 
 	n.lock.Lock()
 	defer n.lock.Unlock()
 	if ch, ok = n.executions[key]; !ok {
-		fmt.Println("    ↳ Making new channel")
 		ch = make(chan struct{})
 		n.executions[key] = ch
 	}