diff --git a/tests/services/test_job_service.py b/tests/services/test_job_service.py
new file mode 100644
index 0000000..df58d2f
--- /dev/null
+++ b/tests/services/test_job_service.py
@@ -0,0 +1,38 @@
+import pytest
+
+
+class TestJobService:
+    class TestBasicCRUD:
+        @pytest.mark.asyncio
+        async def test_create_job(self):
+            """Test creating a job."""
+
+        @pytest.mark.asyncio
+        async def test_reading_job(self):
+            """Test reading a job."""
+
+        @pytest.mark.asyncio
+        async def test_updating_job(self):
+            """Test updating a job."""
+
+        @pytest.mark.asyncio
+        async def test_deleting_job(self):
+            """Test deleting a job."""
+
+    class TestServiceMethods:
+        @pytest.mark.asyncio
+        async def test_query_jobs(self):
+            """Test querying jobs."""
+
+        @pytest.mark.asyncio
+        async def test_list_jobs(self):
+            """Test listing jobs."""
+
+        @pytest.mark.asyncio
+        async def test_mark_job_status(self):
+            """Test marking a job with a new status."""
+
+    class TestMultipleOperations:
+        @pytest.mark.asyncio
+        async def test_multiple_operations(self):
+            """Test multiple operations on jobs."""
diff --git a/tests/services/test_service_base.py b/tests/services/test_service_base.py
new file mode 100644
index 0000000..71c8b82
--- /dev/null
+++ b/tests/services/test_service_base.py
@@ -0,0 +1,36 @@
+import pytest
+
+
+class TestServiceBase:
+    class TestInitialization:
+        def test_initializes_with_defaults(self):
+            """Test initialization with default session factory and queue."""
+
+        def test_initializes_with_custom_session_factory(self):
+            """Test initialization with a provided session factory."""
+
+        def test_initializes_with_custom_queue(self):
+            """Test initialization with a provided queue."""
+
+    class TestSessionScope:
+        @pytest.mark.asyncio
+        async def test_uses_provided_session(self):
+            """Test that session scope reuses a provided session."""
+
+        @pytest.mark.asyncio
+        async def test_creates_new_session_when_none_provided(self):
+            """Test that session scope creates a new session when none is provided."""
+
+    class TestContextManagerBehavior:
+        @pytest.mark.asyncio
+        async def test_yields_session(self):
+            """Test that session scope yields a usable session object."""
+
+        @pytest.mark.asyncio
+        async def test_multiple_operations(self):
+            """Test multiple operations within a single session scope."""
+
+    class TestEdgeCases:
+        @pytest.mark.asyncio
+        async def test_handles_exception_propagation(self):
+            """Test exception propagation behavior inside session scope."""