fix

Signed-off-by: oliver könig <[email protected]>

Author: ko3n1g

nemo_run/core/execution/dgxcloud.py

@@ -367,12 +367,12 @@ def _stream_url_sync(self, url: str, headers: Dict[str, str], q: queue.Queue):
         try:
             with requests.get(url, stream=True, headers=headers, verify=False) as response:
                 for line in response.iter_lines(decode_unicode=True):
-                    q.put(url, f"{line}\n")
+                    q.put((url, f"{line}\n"))
         except Exception as e:
             logger.error(f"Error streaming URL {url}: {e}")
 
         finally:
-            q.put(url, None)
+            q.put((url, None))
 
     def fetch_logs(
         self,