@@ -18,13 +18,13 @@ jobs:
1818
1919 strategy :
2020 matrix :
21- # TODO: rewrite asyncio_reduce example using latest SDK version, as it is currently using old methods
22- # then add to example_directories matrix
2321 example_directories : [
2422 " examples/map/even_odd" , "examples/map/flatmap", "examples/map/forward_message",
25- " examples/map/multiproc_map" , "examples/mapstream/flatmap_stream", "examples/reduce/counter",
26- " examples/reducestream/counter" , "examples/reducestream/sum", "examples/sideinput/simple_sideinput",
27- " examples/sideinput/simple_sideinput/udf" , "examples/sink/async_log", "examples/sink/log",
23+ " examples/map/multiproc_map" , "examples/mapstream/flatmap_stream",
24+ " examples/reduce/counter" , "examples/reduce/asyncio_reduce",
25+ " examples/reducestream/counter" , "examples/reducestream/sum",
26+ " examples/sideinput/simple_sideinput" , "examples/sideinput/simple_sideinput/udf",
27+ " examples/sink/async_log" , "examples/sink/log", "examples/sink/all_sinks",
2828 " examples/source/simple_source" , "examples/sourcetransform/event_time_filter",
2929 " examples/batchmap/flatmap" , "examples/accumulator/streamsorter"
3030 ]
0 commit comments