@@ -781,9 +781,7 @@ def _auto_tune_parallel(self) -> None:
781781 self .max_parallel = 1
782782 logger .info (f"Auto-tuned max_parallel={ self .max_parallel } (PDU={ self .pdu_length } )" )
783783
784- def _send_receive_parallel (
785- self , requests : list [Tuple [int , bytes ]]
786- ) -> dict [int , dict [str , Any ]]:
784+ def _send_receive_parallel (self , requests : list [Tuple [int , bytes ]]) -> dict [int , dict [str , Any ]]:
787785 """Fire multiple S7 requests back-to-back and collect responses by sequence number.
788786
789787 All PDUs are sent on the single TCP connection before reading any
@@ -910,19 +908,15 @@ def _read_multi_vars_optimized(self, dict_items: List[dict[str, Any]]) -> Tuple[
910908 results = extract_results (working_packets , len (dict_items ))
911909 return (0 , results )
912910
913- def _execute_packets_sequential (
914- self , packet_requests : list [Tuple [int , bytes , ReadPacket ]]
915- ) -> None :
911+ def _execute_packets_sequential (self , packet_requests : list [Tuple [int , bytes , ReadPacket ]]) -> None :
916912 """Execute multi-block packets one at a time."""
917913 for _ , request , packet in packet_requests :
918914 response = self ._send_receive (request )
919915 block_data_list = self .protocol .extract_multi_read_data (response , len (packet .blocks ))
920916 for blk , buf in zip (packet .blocks , block_data_list ):
921917 blk .buffer = buf
922918
923- def _execute_packets_parallel (
924- self , packet_requests : list [Tuple [int , bytes , ReadPacket ]]
925- ) -> None :
919+ def _execute_packets_parallel (self , packet_requests : list [Tuple [int , bytes , ReadPacket ]]) -> None :
926920 """Execute multi-block packets using parallel dispatch.
927921
928922 Sends up to *max_parallel* PDUs back-to-back before reading
0 commit comments