From 5792fb331fd859d065f11e8505459a76c27cf48e Mon Sep 17 00:00:00 2001
From: Andre LeBlanc <andre.leblanc@webfilings.com>
Date: Wed, 9 Sep 2015 23:12:55 -0400
Subject: [PATCH] encode / decode _process_results

---
 furious/async.py            |  7 +++++++
 furious/tests/test_async.py | 16 ++++++++++++++++
 2 files changed, 23 insertions(+)

diff --git a/furious/async.py b/furious/async.py
index 259e9d0..f68c0b8 100644
--- a/furious/async.py
+++ b/furious/async.py
@@ -596,6 +596,10 @@ def encode_async_options(async):
         _checker = options.pop('_context_checker')
         options['__context_checker'] = reference_to_path(_checker)
 
+    if '_process_results' in options:
+        _processor = options.pop('_process_results')
+        options['__process_results'] = reference_to_path(_processor)
+
     return options
 
 
@@ -619,6 +623,9 @@ def decode_async_options(options):
         _checker = options['__context_checker']
         async_options['_context_checker'] = path_to_reference(_checker)
 
+    if '__process_results' in options:
+        _processor = options['__process_results']
+        async_options['_process_results'] = path_to_reference(_processor)
     return async_options
 
 
diff --git a/furious/tests/test_async.py b/furious/tests/test_async.py
index 9fc930a..419c877 100644
--- a/furious/tests/test_async.py
+++ b/furious/tests/test_async.py
@@ -961,6 +961,22 @@ def test_context_checker_encoded_and_decoded(self):
 
         self.assertEqual(async_job.to_dict(), new_async_job.to_dict())
 
+    def test_process_results_encoded_and_decoded(self):
+        """Ensure _process_results is correctly encoded to and decoded from
+        an Async options dict.
+        """
+        from furious.async import Async
+
+        async_job = Async("something", _process_results=locals)
+
+        encoded_async = async_job.to_dict()
+        self.assertEqual(encoded_async['__process_results'], 'locals')
+
+        new_async_job = Async.from_dict(encoded_async)
+        self.assertEqual(new_async_job.get_options()['_process_results'], locals)
+
+        self.assertEqual(async_job.to_dict(), new_async_job.to_dict())
+
     def test_retry_value_is_decodable(self):
         """Ensure that from_dict is the inverse of to_dict when retry options
         are given.