Use BROKER_URL in priority

Author: codeSamuraii

examples/package_installation.py

@@ -75,7 +75,7 @@ def handle_endtag(self, tag: str) -> None:
             if tag == "title":
                 self.in_title = False
 
-    resp = requests.get(url, timeout=10)
+    resp = requests.get(url, timeout=5.0)
     parser = TitleParser()
     parser.feed(resp.text)
     return parser.title.strip()
@@ -134,7 +134,7 @@ async def main() -> None:
 
     # Simple package (import name == pip name)
     print("--- requests (auto-detected) ---")
-    title = await fetch_title.run("http://example.com")
+    title = await fetch_title.run("https://example.com")
     print(f"  Page title: {title}")
 
     # Mismatched package names

offwork/__main__.py

@@ -363,12 +363,14 @@ async def _cmd_run_async(args: argparse.Namespace) -> None:
         print(f"Error: script not found: {script}", file=sys.stderr)
         sys.exit(1)
 
+    print(f"== Running: {script.relative_to(Path.cwd())} - venv: ...", end="", file=sys.stderr, flush=True)
     extras = _collect_extras(args, script)
     detected = _detect_script_packages(str(script))
 
     async with temp_venv(install_offwork=True, extras=extras) as venv:
+        print("\b"*3 + f"{venv.venv_dir}", file=sys.stderr, flush=True)
         if detected:
-            print(f"Installing detected dependencies: {', '.join(detected)}", file=sys.stderr)
+            print(f"== Installing dependencies: {', '.join(detected)}", file=sys.stderr)
             await venv.pip_install(*detected, extra_args=["--quiet"])
 
         script_args = list(args.script_args or [])

offwork/_venv.py

@@ -123,7 +123,6 @@ async def temp_venv(
     def _cleanup() -> None:
         if os.path.isdir(tmpdir):
             logger.info("Cleaning up temporary venv at %s", tmpdir)
-            print(f"Cleaning up temporary venv at {tmpdir}...", file=sys.stderr)
             shutil.rmtree(tmpdir, ignore_errors=True)
 
     # Safety net: atexit ensures cleanup even if the context manager is
@@ -143,8 +142,7 @@ def _sigterm_handler(signum: int, frame: FrameType | None) -> None:
 
     try:
         venv_dir = Path(tmpdir) / "venv"
-        logger.info("Creating temporary venv at %s", venv_dir)
-        print("Creating temporary virtual environment...", file=sys.stderr)
+        logger.info("Creating temporary venv: %s", venv_dir)
         loop = asyncio.get_running_loop()
         await loop.run_in_executor(
             None, lambda: venv.create(str(venv_dir), with_pip=True)
@@ -164,7 +162,6 @@ def _sigterm_handler(signum: int, frame: FrameType | None) -> None:
                 spec = "offwork"
             if extras:
                 spec += f"[{','.join(extras)}]"
-            print("Installing offwork into temporary venv...", file=sys.stderr)
             await tv.pip_install(spec, extra_args=["--quiet"])
 
         yield tv

offwork/worker/remote.py

@@ -44,7 +44,10 @@
 
 
 def _resolve_url(url: str | None) -> str:
-    """Return *url* if given, otherwise read from the environment variable."""
+    """Return BROKER_URL, then url, then OFFWORK_BACKEND env var."""
+    broker_url = os.environ.get("BROKER_URL")
+    if broker_url:
+        return broker_url
     if url is not None:
         return url
     env_url = os.environ.get(_ENV_VAR)