diff --git a/sdks/python/apache_beam/transforms/userstate_test.py b/sdks/python/apache_beam/transforms/userstate_test.py index 084afcf63491..50d41baf62d0 100644 --- a/sdks/python/apache_beam/transforms/userstate_test.py +++ b/sdks/python/apache_beam/transforms/userstate_test.py @@ -992,6 +992,7 @@ def emit_callback( self.assertEqual([('emit1', 10), ('emit2', 20), ('emit3', 30)], sorted(StatefulDoFnOnDirectRunnerTest.all_records)) + @pytest.mark.no_xdist @pytest.mark.timeout(3) def test_dynamic_timer_clear_then_set_timer(self): class EmitTwoEvents(DoFn):