@@ -404,8 +404,8 @@ cdef class Buffer:
404404 @classmethod
405405 def from_ipc_descriptor(
406406 cls , mr: DeviceMemoryResource | PinnedMemoryResource | VirtualMemoryResource ,
407- ipc_descriptor: IPCBufferDescriptor ,
408- *, stream: Stream
407+ IPCBufferDescriptor ipc_descriptor not None : IPCBufferDescriptor ,
408+ *, Stream stream not None : Stream
409409 ) -> Buffer:
410410 """Import a buffer that was exported from another process.
411411
@@ -505,7 +505,7 @@ cdef class Buffer:
505505 self .close()
506506 return False
507507
508- def copy_to (self , dst: Buffer | None = None , *, stream: Stream | GraphBuilder ,
508+ def copy_to (self , Buffer dst: Buffer | None = None , *, stream: Stream | GraphBuilder ,
509509 options: CopyOptions | None = None ) -> Buffer:
510510 """Copy from this buffer to the dst buffer asynchronously on the given stream.
511511
@@ -555,7 +555,7 @@ cdef class Buffer:
555555 "buffer does not have a memory_resource )")
556556 dst = self ._memory_resource.allocate(src_size, stream = s)
557557 else:
558- Buffer_check_open(<Buffer> dst )
558+ Buffer_check_open(dst )
559559
560560 cdef size_t dst_size = dst._size
561561 if dst_size != src_size:
@@ -566,7 +566,7 @@ cdef class Buffer:
566566 as_cu(dst._h_ptr ), as_cu(self._h_ptr ), src_size , s , options , "copy_to")
567567 return dst
568568
569- def copy_from(self , src: Buffer , *, stream: Stream | GraphBuilder ,
569+ def copy_from(self , Buffer src not None : Buffer , *, stream: Stream | GraphBuilder ,
570570 options: CopyOptions | None = None ) -> None:
571571 """Copy from the src buffer to this buffer asynchronously on the given stream.
572572
0 commit comments