Using condition broadcast

go.mod

@@ -180,7 +180,7 @@ require (
 )
 
 replace (
-	github.com/flyteorg/flyte/flyteidl => github.com/flyteorg/flyte/flyteidl v1.12.0-b0.0.20240503025718-07c0f238650c
+	github.com/flyteorg/flyte/flyteidl => github.com/flyteorg/flyte/flyteidl v1.12.0-b0.0.20240517165944-d066b2050575
 	github.com/flyteorg/flyte/flyteplugins => github.com/flyteorg/flyte/flyteplugins v1.12.0-b0.0.20240503025718-07c0f238650c
 	github.com/flyteorg/flyte/flytepropeller => github.com/flyteorg/flyte/flytepropeller v1.12.0-b0.0.20240503025718-07c0f238650c
 	github.com/flyteorg/flyte/flytestdlib => github.com/flyteorg/flyte/flytestdlib v1.12.0-b0.0.20240503025718-07c0f238650c

go.sum

@@ -352,8 +352,8 @@ github.com/fatih/color v1.13.0 h1:8LOYc1KYPPmyKMuN8QV2DNRWNbLo6LZ0iLs8+mlH53w=
 github.com/fatih/color v1.13.0/go.mod h1:kLAiJbzzSOZDVNGyDpeOxJ47H46qBXwg5ILebYFFOfk=
 github.com/felixge/httpsnoop v1.0.4 h1:NFTV2Zj1bL4mc9sqWACXbQFVBBg2W3GPvqp8/ESS2Wg=
 github.com/felixge/httpsnoop v1.0.4/go.mod h1:m8KPJKqk1gH5J9DgRY2ASl2lWCfGKXixSwevea8zH2U=
-github.com/flyteorg/flyte/flyteidl v1.12.0-b0.0.20240503025718-07c0f238650c h1:A/0v44t9wFbG3Q3Ll2v0D9XGIR5n3D6KumCOfZkOVzg=
-github.com/flyteorg/flyte/flyteidl v1.12.0-b0.0.20240503025718-07c0f238650c/go.mod h1:mKC19e/327nx6ouAWtrcZt0vFWl0/IFxXwyb+Ff9/wY=
+github.com/flyteorg/flyte/flyteidl v1.12.0-b0.0.20240517165944-d066b2050575 h1:GAkFzSPzCOQOQR/WM5+4Zchw2LmOHJPiIBNwTOxnoJo=
+github.com/flyteorg/flyte/flyteidl v1.12.0-b0.0.20240517165944-d066b2050575/go.mod h1:mKC19e/327nx6ouAWtrcZt0vFWl0/IFxXwyb+Ff9/wY=
 github.com/flyteorg/flyte/flyteplugins v1.12.0-b0.0.20240503025718-07c0f238650c h1:ehuea7v/q0hZxyIMuO8NYUcfgAEUAOvv4Tyk5i0y644=
 github.com/flyteorg/flyte/flyteplugins v1.12.0-b0.0.20240503025718-07c0f238650c/go.mod h1:bnW+Jb8u60I7FlufsCu/nE7XZZOlY4m7ngWPA7YFnQc=
 github.com/flyteorg/flyte/flytepropeller v1.12.0-b0.0.20240503025718-07c0f238650c h1:JRzMLhFKiRtDj6f/U/RxaCsl8iBcS57SfA69USKVrE4=

pkg/pkce/token_cache_keyring.go

@@ -67,11 +67,9 @@ func (t *TokenCacheKeyringProvider) CondWait() {
 	logger.Infof(context.Background(), "Coming out of waiting")
 }
 
-// CondSignal signals the condition.
-func (t *TokenCacheKeyringProvider) CondSignal() {
-	logger.Infof(context.Background(), "Signaling the condition")
-	t.cond.Signal()
-	logger.Infof(context.Background(), "Signaled the condition")
+// CondBroadcast broadcasts the condition.
+func (t *TokenCacheKeyringProvider) CondBroadcast() {
+	t.cond.Broadcast()
 }
 
 func (t *TokenCacheKeyringProvider) SaveToken(token *oauth2.Token) error {