Handle KeyboardInterrupt cleanly in workers

Add top-level KeyboardInterrupt handler to Worker.run() that:
- Logs "worker_interrupted" at debug level
- Exits with code 130 (128 + SIGINT signal number)
- Avoids printing a traceback

This provides a cleaner user experience when pressing Ctrl+C instead
of showing a full Python traceback.

Also fix line-length lint errors in table_function.py and
table_in_out_function.py for protocol state metadata construction.

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>

Author: rustyconover

vgi/table_function.py

@@ -149,9 +149,7 @@ class ProtocolOutput:
     batch: pa.RecordBatch | None
     log_message: vgi.log.Message | None = None
 
-    def metadata(
-        self, invocation: vgi.invocation.Invocation
-    ) -> pa.KeyValueMetadata:
+    def metadata(self, invocation: vgi.invocation.Invocation) -> pa.KeyValueMetadata:
         """Create metadata for this output based on the status.
 
         Args:
@@ -164,9 +162,9 @@ def metadata(
 
         """
         # Start with protocol state (required for VGI protocol)
-        metadata_dict: dict[bytes, bytes] = {
-            vgi.ipc_utils.PROTOCOL_STATE_KEY: vgi.ipc_utils.ProtocolState.OUTPUT.encode()
-        }
+        protocol_key = vgi.ipc_utils.PROTOCOL_STATE_KEY
+        protocol_state = vgi.ipc_utils.ProtocolState.OUTPUT.encode()
+        metadata_dict: dict[bytes, bytes] = {protocol_key: protocol_state}
 
         # Add log message metadata if present
         if self.log_message is not None:

vgi/table_in_out_function.py

@@ -159,9 +159,7 @@ class ProtocolOutput:
     status: _OutputStatus
     log_message: vgi.log.Message | None = None
 
-    def metadata(
-        self, invocation: vgi.invocation.Invocation
-    ) -> pa.KeyValueMetadata:
+    def metadata(self, invocation: vgi.invocation.Invocation) -> pa.KeyValueMetadata:
         """Create metadata for this output based on the status.
 
         Args:
@@ -174,8 +172,10 @@ def metadata(
 
         """
         # Start with protocol state (required for VGI protocol) and status
+        protocol_key = vgi.ipc_utils.PROTOCOL_STATE_KEY
+        protocol_state = vgi.ipc_utils.ProtocolState.OUTPUT.encode()
         metadata_dict: dict[bytes, bytes] = {
-            vgi.ipc_utils.PROTOCOL_STATE_KEY: vgi.ipc_utils.ProtocolState.OUTPUT.encode(),
+            protocol_key: protocol_state,
             b"vgi.status": self.status.value.encode(),
         }
 

vgi/worker.py

@@ -1432,6 +1432,16 @@ def run(self) -> None:
 
         tracer = tracing.get_tracer("vgi.worker")
 
+        try:
+            self._run_loop(tracer)
+        except KeyboardInterrupt:
+            # Exit cleanly on Ctrl+C without traceback
+            # Exit code 130 = 128 + SIGINT(2), conventional for interrupted processes
+            self.log.debug("worker_interrupted")
+            sys.exit(130)
+
+    def _run_loop(self, tracer: Any) -> None:
+        """Run the main worker loop for processing invocations."""
         try:
             while True:
                 self.log.info("waiting_for_invocation")