tree 99afc96db7ff1d94e3ee2423ed7a1509b66c1311
parent 88d5f59c764c096d46a5ca0eaa1729aa87e1bc4b
author Rob Suderman <rob.suderman@gmail.com> 1736787453 -0800
committer GitHub <noreply@github.com> 1736787453 -0800
gpgsig -----BEGIN PGP SIGNATURE-----
 
 wsFcBAABCAAQBQJnhUX9CRC1aQ7uu5UhlAAAz8YQAHwPSacv2IqG92smrGm29f5N
 2dCsBMNx3N5PkEDd9a/CN6XbyhttzgdMXDggTlcSq82Iv58/Bd4488+s4KyNNAFM
 nAlyNFO1VU4hF+qiNJ9OJOZIM6tfhF4wVDNis5YsWyn96X5mZTku6y1l+wY+4Ow6
 r2o+iqqsepKHdsPQdilMmX0qA+DgnfrCnEvIrB1RtGyjXV7zB86RPEMUYIQc22ox
 jHMYZWyrGwDHv6ZZGyh7+BC9Ve8mnABC+dQHzx6iIKbatMEy1hQXwSWrvBfgNiFm
 zW0U8zWIA2r2ystauPvUyptm0ifYfBnuxHJKDgYsqeVN30sL7zVzaUrCo4xHOkv1
 Ls/sws3TLNuf/d7XLySDK9Go11TTrGglr/NJ9BYLwtVgERB6psQRohhic4Jn5Y+R
 eUItD7L2bQJ1gv1UDqcIH3slivWYpGZ5ysE3bNzKZ79WyJt50Jqi/2cgBP2+gj5s
 Yvwm/s6ohy7p1yK3h6yCglxRmhwFbVXjTtVu4ORjVqFYE3Uj6GRr5JX110CBBki5
 t5cD1oF82OV4BwgXrFdbLaK4hSN32sEM5Ky3uj+DY+SnMaf1dbNLXurRspiqYcuu
 xZXsxuUp+P9GS7iDGpRuR4DKNbEFN0+3dkoGwd7VTn9IzpuKJLrv6GKRbXKkfvlI
 xchReFWskohdXHbXfRiX
 =e0Of
 -----END PGP SIGNATURE-----
 

Better support multidevice placement with `stream.async.barrier` (#19651)

Barriers / transfers should have semantics that attempt to parallelize
partitioning. If a value has a barrier placed it should divide
partitions to avoid spaning behavior with cross device dependencies.

Intermediate and ending transfers we want to place on the producing
partition so that any produced operator ends by producing the value at
the needed desetination

For incoming transfers we place in the destination partition as these
will not add a dependency on the incoming data.