update

Author: ji-huazhong

verl/utils/transferqueue_utils.py

@@ -20,9 +20,12 @@
 import numpy as np
 import torch
 from tensordict import NonTensorData, NonTensorStack, TensorDict
-from transfer_queue import AsyncTransferQueueClient, BatchMeta
 
-from verl.experimental.transfer_queue import ZMQServerInfo
+from verl.experimental.transfer_queue import (
+    AsyncTransferQueueClient,
+    BatchMeta,
+    ZMQServerInfo,
+)
 from verl.protocol import DataProto
 
 # _TRANSFER_QUEUE_CONTROLLER_INFOS = None