Clean message config to remove unserializable items

example/definitions/executor.yaml

@@ -7,7 +7,6 @@ spec:
   type: ProcessExecutor
   options:
     max_workers: 1
-    pool_type: thread
 ---
 apiVersion: saturn.flared.io/v1alpha1
 kind: SaturnExecutor

src/saturn_engine/worker/executors/arq/executor.py

@@ -62,7 +62,7 @@ async def process_message(self, message: ExecutableMessage) -> PipelineResults:
         try:
             job = await (await self.redis_queue).enqueue_job(
                 EXECUTE_FUNC_NAME,
-                message.message,
+                message.message.as_remote(),
                 _expires=options.queue_timeout,
                 _queue_name=options.queue_name,
             )

src/saturn_engine/worker/executors/process.py

@@ -71,7 +71,7 @@ def __init__(self, options: Options, services: Services) -> None:
 
     async def process_message(self, message: ExecutableMessage) -> PipelineResults:
         loop = asyncio.get_running_loop()
-        execute = partial(self.remote_execute, message=message.message)
+        execute = partial(self.remote_execute, message=message.message.as_remote())
         return await loop.run_in_executor(self.pool_executor, execute)
 
     @property

src/saturn_engine/worker/pipeline_message.py

@@ -57,3 +57,8 @@ def execute(self) -> object:
 
         pipeline_args = fromdict(args, pipeline_args_def)
         return pipeline_args.call(kwargs=args)
+
+    def as_remote(self) -> "PipelineMessage":
+        return dataclasses.replace(
+            self, message=dataclasses.replace(self.message, config={})
+        )