From 57dd248c8e13fdde5dd3f1b547bf86071afc0c5e Mon Sep 17 00:00:00 2001 From: Seth Foster Date: Mon, 26 Sep 2022 15:27:39 -0400 Subject: [PATCH] Pass startpos for work results --- receptorctl/receptorctl/socket_interface.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/receptorctl/receptorctl/socket_interface.py b/receptorctl/receptorctl/socket_interface.py index 16e836df6..7847553e1 100644 --- a/receptorctl/receptorctl/socket_interface.py +++ b/receptorctl/receptorctl/socket_interface.py @@ -245,9 +245,11 @@ def submit_work( result = json.loads(text) return result - def get_work_results(self, unit_id, return_socket=False, return_sockfile=True): + def get_work_results( + self, unit_id, startpos=0, return_socket=False, return_sockfile=True + ): self.connect() - self.writestr(f"work results {unit_id}\n") + self.writestr(f"work results {unit_id} {startpos}\n") text = self.readstr() m = re.compile("Streaming results for work unit (.+)").fullmatch(text) if not m: