feat: always include func_file in task serialization to support modules not in Python path

Author: adamrefaey

src/asynctasq/tasks/services/serializer.py

@@ -53,9 +53,13 @@ def serialize(self, task: BaseTask) -> bytes:
             func = task.func  # type: ignore[attr-defined]
             func_module = func.__module__
             func_name = func.__name__
-            # Store func_file if it's __main__ module
-            if func_module == "__main__":
+            # Always store func_file to support modules not in Python path
+            # This allows workers to load the module from file if import fails
+            try:
                 func_file = func.__code__.co_filename
+            except AttributeError:
+                # Built-in or C extension functions don't have __code__
+                pass
 
             # IMPORTANT: For FunctionTask, individual kwargs are stored as instance attributes
             # (e.g., self.user = user_value) but they're also in self.kwargs.

tests/unit/core/test_dispatcher.py

@@ -582,7 +582,9 @@ def test_func(x: int, y: str) -> str:
         assert call_arg["class"] == f"{FunctionTask.__module__}.{FunctionTask.__name__}"
         assert call_arg["metadata"]["func_name"] == "test_func"
         assert call_arg["metadata"]["func_module"] == test_func.__module__
-        assert "func_file" not in call_arg["metadata"]  # Not __main__ module
+        # func_file is now always included to support modules not in Python path
+        assert "func_file" in call_arg["metadata"]
+        assert call_arg["metadata"]["func_file"].endswith("test_dispatcher.py")
 
     def test_serialize_function_task_handles_main_module_with_file_path(self) -> None:
         # Arrange
@@ -673,9 +675,13 @@ def test_serialize_function_task_handles_main_module_type_error(self) -> None:
         task._current_attempt = 0
         task._dispatched_at = datetime(2024, 1, 1, 12, 0, 0, tzinfo=UTC)
 
-        # Act & Assert - should raise AttributeError when trying to access __code__
-        with raises(AttributeError):
-            dispatcher._task_serializer.serialize(task)
+        # Act - should handle AttributeError gracefully and not include func_file
+        dispatcher._task_serializer.serialize(task)
+
+        # Assert - func_file should not be present when __code__ is unavailable
+        mock_serializer.serialize.assert_called_once()
+        call_arg = mock_serializer.serialize.call_args[0][0]
+        assert "func_file" not in call_arg["metadata"]
 
     def test_serialize_function_task_excludes_func_from_params(self) -> None:
         # Arrange