comment

Signed-off-by: Julie Vogelman <[email protected]>
numaproj · Jan 16, 2025 · 09404c6 · 09404c6
1 parent dd1b8c4
commit 09404c6
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/pkg/mapper/examples/cat_sleep/main.go b/pkg/mapper/examples/cat_sleep/main.go
@@ -17,6 +17,7 @@ type CatSleep struct {
 
 func (e *CatSleep) Map(ctx context.Context, keys []string, d mapper.Datum) mapper.Messages {
 
+	// sleep for as long as the environment variable indicates (or default if not configured)
 	sleepSeconds := DEFAULT_SLEEP_SECONDS
 	secondsString := os.Getenv("SLEEP_SECONDS")
 	if secondsString == "" {