ΑisSSKJr SSKJrJr SSKrSSKJr SSKJ r J r SSK J r \(aSSKJ r SSKJr SS KJr S SS jjrSSS jjrSSS jjrg)) annotations) TYPE_CHECKINGAnyN)stream)_get_global_group_warn_cur_rank_not_in_group)convert_object_to_tensor)Tensor)task)Groupc.[R"XX#SS9$)a Send a tensor to the receiver. Args: tensor (Tensor): The Tensor to send. Its data type should be float16, float32, float64, int32, int64, int8, uint8, bool or bfloat16. dst (int): The destination rank id. group (Group, optional): The group instance return by new_group or None for global default group. Default: None. sync_op (bool, optional): Whether this op is a sync op. The default value is True. Returns: Return a task object. Examples: .. code-block:: python >>> # doctest: +REQUIRES(env: DISTRIBUTED) >>> import paddle >>> import paddle.distributed as dist >>> dist.init_parallel_env() >>> if dist.get_rank() == 0: ... data = paddle.to_tensor([7, 8, 9]) ... dist.send(data, dst=1) >>> else: ... data = paddle.to_tensor([1, 2, 3]) ... dist.recv(data, src=0) >>> print(data) >>> # [7, 8, 9] (2 GPUs) F)dstgroupsync_opuse_calc_stream)rsend)tensorrrrs e/var/www/html/banglarbhumi/venv/lib/python3.13/site-packages/paddle/distributed/communication/send.pyrr#sH ;;uu c[XUSS9$)a Send tensor asynchronously Args: tensor (Tensor): The Tensor to send. Its data type should be float16, float32, float64, int32, int64, int8, uint8, bool or bfloat16. dst (int): The destination rank. group (Group, optional): The group instance return by new_group or None for global default group. Default: None. Returns: Return a task object. Warning: This API only supports the dygraph mode. Examples: .. code-block:: python >>> # doctest: +REQUIRES(env: DISTRIBUTED) >>> import paddle >>> import paddle.distributed as dist >>> dist.init_parallel_env() >>> if dist.get_rank() == 0: ... data = paddle.to_tensor([7, 8, 9]) ... task = dist.isend(data, dst=1) >>> else: ... data = paddle.to_tensor([1, 2, 3]) ... task = dist.irecv(data, src=0) >>> task.wait() # type: ignore[union-attr] >>> print(data) >>> # [7, 8, 9] (2 GPUs) F)r)r)rrrs risendrLsF UE 22rcUb[U5S:Xa [S5eUc [5OUn[U5(agUb Ub [S5eUR U5nOUcSOUn[ UVs/sHn[ U5PM sn6upVUVs/sHowR5PM nn[R"USS9n [XUS9 [U5S:XaUSn O[R"U5n [XUS9 gs snfs snf) a Send a list of Python objects to the receiver. Args: object_list (list): The list of Python objects to send. dst (int, optional): The destination rank id. Default: 0. group (Group, optional): The group instance return by new_group or None for global default group. Default: None. dst_in_group (int, optional): The destination rank within the group. Cannot be specified together with dst. Default: None. Returns: This function does not return any value. Examples: .. code-block:: python >>> # doctest: +REQUIRES(env: DISTRIBUTED) >>> import paddle >>> import paddle.distributed as dist >>> dist.init_parallel_env() >>> if dist.get_rank() == 0: ... data = ["hello", {"key": 100}, [1, 2, 3]] ... dist.send_object_list(data, dst=1) >>> else: ... data = [None] * 3 # type: ignore ... dist.recv_object_list(data, src=0) >>> print(data) >>> # ["hello", {"key": 100}, [1, 2, 3]] (2 GPUs) Nrz#object_list cannot be None or emptyz7Cannot specify both 'dst' and 'dst_in_group' arguments.int64)dtype)rr) len ValueErrorrrget_global_rankzipr itempaddle to_tensorrconcat) object_listrr dst_in_groupobj tensor_list size_listsizesize_list_valuesobject_sizes_tensor object_tensors rsend_object_listr-rsFc+.!3>??#(=  eE"5)) ?I ##L1;aC!3> ?;C "3 '; ?K1::  :!**+;7K U3 ;1#A  k2 u- @:s 1DD)rNT) rr rintr Group | Nonerboolreturn task | None)N)rr rr.rr/r1r2)NNN)r$z list[Any]r int | Nonerr/r%r3) __future__rtypingrrr! paddle.distributed.communicationr&paddle.distributed.communication.grouprr4paddle.distributed.communication.serialization_utilsr r paddle.base.corer r rrr-rrr;s#% 3%<  & & & & &  &R#3P# B.B. B. B. B.r