Result middleware: consider message options before actor options (#612)

solves issue #591
Bogdanp · Apr 23, 2024 · e48151e · e48151e
1 parent e6d443e
commit e48151e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/dramatiq/results/middleware.py b/dramatiq/results/middleware.py
@@ -83,8 +83,8 @@ def actor_options(self):
     def _lookup_options(self, broker, message):
         try:
             actor = broker.get_actor(message.actor_name)
-            store_results = actor.options.get("store_results", self.store_results)
-            result_ttl = actor.options.get("result_ttl", self.result_ttl)
+            store_results = message.options.get("store_results", actor.options.get("store_results", self.store_results))
+            result_ttl = message.options.get("result_ttl", actor.options.get("result_ttl", self.result_ttl))
             return store_results, result_ttl
         except ActorNotFound:
             return False, 0