Rename ExtractorAgent -> Executor

We call this component Executor now.

Testing:

make check
make test

python-sdk/indexify/cli.py

@@ -22,7 +22,7 @@
 from rich.text import Text
 from rich.theme import Theme
 
-from indexify.executor.agent import ExtractorAgent
+from indexify.executor.executor import Executor
 from indexify.function_executor.function_executor_service import (
     FunctionExecutorService,
 )
@@ -221,7 +221,7 @@ def executor(
         shutil.rmtree(executor_cache)
     Path(executor_cache).mkdir(parents=True, exist_ok=True)
 
-    agent = ExtractorAgent(
+    executor = Executor(
         id,
         server_addr=server_addr,
         config_path=config_path,
@@ -232,7 +232,7 @@ def executor(
     )
 
     try:
-        asyncio.get_event_loop().run_until_complete(agent.run())
+        asyncio.get_event_loop().run_until_complete(executor.run())
     except asyncio.CancelledError:
         logger.info("graceful shutdown")
 

python-sdk/indexify/executor/agent.py → python-sdk/indexify/executor/executor.py

@@ -23,7 +23,7 @@
 from .task_reporter import TaskReporter
 
 
-class ExtractorAgent:
+class Executor:
     def __init__(
         self,
         executor_id: str,

python-sdk/tests/test_extractor_agent_behaviour.py → python-sdk/tests/test_executor_behaviour.py

@@ -10,7 +10,7 @@
     service_url,
 )
 
-from indexify.executor.agent import ExtractorAgent
+from indexify.executor.executor import Executor
 
 
 class TestExtractorAgent(unittest.TestCase):
@@ -28,8 +28,8 @@ class TestExtractorAgent(unittest.TestCase):
     @patch("httpx.Client")
     @patch("httpx.AsyncClient")
     def test_tls_configuration(self, mock_async_client, mock_sync_client, mock_file):
-        # Create an instance of ExtractorAgent with the mock config
-        agent = ExtractorAgent(
+        # Create an instance of Executor with the mock config
+        executor = Executor(
             executor_id="unit-test",
             code_path=Path("test"),
             server_addr=service_url,
@@ -53,20 +53,20 @@ def test_tls_configuration(self, mock_async_client, mock_sync_client, mock_file)
             verify=ca_bundle_path,
         )
 
-        # Verify TLS config in Agent
-        self.assertEqual(agent._server_addr, service_url)
-        self.assertTrue(agent._base_url.startswith("https://"))
+        # Verify TLS config in Executor
+        self.assertEqual(executor._server_addr, service_url)
+        self.assertTrue(executor._base_url.startswith("https://"))
 
     def test_no_tls_configuration(self):
-        # Create an instance of ExtractorAgent without TLS
-        agent = ExtractorAgent(
+        # Create an instance of Executor without TLS
+        executor = Executor(
             executor_id="unit-test",
             code_path=Path("test"),
             server_addr="localhost:8900",
         )
 
         # Verify the protocol is set to "http"
-        self.assertTrue(agent._base_url.startswith("http://"))
+        self.assertTrue(executor._base_url.startswith("http://"))
 
 
 if __name__ == "__main__":