diff --git a/sdks/go/test/integration/primitives/timers.go b/sdks/go/test/integration/primitives/timers.go index ab3454b64ce2..b4443296ecce 100644 --- a/sdks/go/test/integration/primitives/timers.go +++ b/sdks/go/test/integration/primitives/timers.go @@ -35,7 +35,6 @@ func init() { register.DoFn6x0[beam.Window, state.Provider, timers.Provider, string, int, func(kv[string, int])](&eventTimeFn{}) register.Emitter2[string, int]() register.Emitter1[kv[string, int]]() - register.Iter1[int]() } type kv[K, V any] struct { @@ -139,13 +138,13 @@ func timersEventTimePipelineBuilder(makeImp func(s beam.Scope) beam.PCollection) } } -// TimersEventTime_Bounded validates event time timers in a bounded pipeline. -func TimersEventTime_Bounded(s beam.Scope) { +// TimersEventTimeBounded validates event time timers in a bounded pipeline. +func TimersEventTimeBounded(s beam.Scope) { timersEventTimePipelineBuilder(beam.Impulse)(s) } -// TimersEventTime_Bounded validates event time timers in an unbounded pipeline. -func TimersEventTime_Unbounded(s beam.Scope) { +// TimersEventTimeUnbounded validates event time timers in an unbounded pipeline. +func TimersEventTimeUnbounded(s beam.Scope) { timersEventTimePipelineBuilder(func(s beam.Scope) beam.PCollection { now := time.Now() return periodic.Impulse(s, now, now.Add(10*time.Second), 0, false) diff --git a/sdks/go/test/integration/primitives/timers_test.go b/sdks/go/test/integration/primitives/timers_test.go index 631ba41b91f2..01f2706c6293 100644 --- a/sdks/go/test/integration/primitives/timers_test.go +++ b/sdks/go/test/integration/primitives/timers_test.go @@ -24,12 +24,12 @@ import ( func TestTimers_EventTime_Bounded(t *testing.T) { integration.CheckFilters(t) - ptest.BuildAndRun(t, TimersEventTime_Bounded) + ptest.BuildAndRun(t, TimersEventTimeBounded) } func TestTimers_EventTime_Unbounded(t *testing.T) { integration.CheckFilters(t) - ptest.BuildAndRun(t, TimersEventTime_Unbounded) + ptest.BuildAndRun(t, TimersEventTimeUnbounded) } // TODO(https://github.com/apache/beam/issues/29772): Add ProcessingTime Timer tests.