Pass startpos for work results

ansible · Sep 27, 2022 · 57dd248 · 57dd248
1 parent 72a97e5
commit 57dd248
Showing 1 changed file with 4 additions and 2 deletions.
diff --git 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: