Skip to content

Commit

Permalink
add missing replying arg (#2620)
Browse files Browse the repository at this point in the history
  • Loading branch information
yanchengnv committed Jun 7, 2024
1 parent 5498c7d commit 1401401
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions nvflare/apis/utils/reliable_message.py
Original file line number Diff line number Diff line change
Expand Up @@ -93,6 +93,7 @@ def __init__(self, topic, request_handler_f, executor, per_msg_timeout, tx_timeo
self.source = None
self.tx_id = None
self.reply_time = None
self.replying = False

def process(self, request: Shareable, fl_ctx: FLContext) -> Shareable:
self.tx_id = request.get_header(HEADER_TX_ID)
Expand Down

0 comments on commit 1401401

Please sign in to comment.