DX Improvements

src/resonate/encoders.py

@@ -29,18 +29,6 @@ def decode(self, data: str) -> str:
         return base64.b64decode(data).decode()
 
 
-# Helper method to make Errors serializable
-def _default(data: Any) -> Any:  # noqa: ANN401
-    if isinstance(data, Exception):
-        return {
-            "__type": _classname(data),
-            "attributes": data.__dict__,
-        }
-
-    return data
-
-
-# Helper method to deserialize errors
 def _object_hook(data: dict[str, Any]) -> Any:  # noqa: ANN401
     if "__type" in data:
         error_cls = _import_class_from_qualified_name(data["__type"])
@@ -52,7 +40,12 @@ def _object_hook(data: dict[str, Any]) -> Any:  # noqa: ANN401
 @final
 class JsonEncoder(IEncoder[Any, str]):
     def encode(self, data: Any) -> str:  # noqa: ANN401
-        return json.dumps(data, default=_default)
+        if isinstance(data, Exception):
+            data = {
+                "__type": _classname(data),
+                "attributes": data.__dict__,
+            }
+        return json.dumps(data)
 
     def decode(self, data: str) -> Any:  # noqa: ANN401
         return json.loads(data, object_hook=_object_hook)

src/resonate/scheduler/scheduler.py

@@ -238,6 +238,12 @@ def _handle_complete(
         if isinstance(record, str):
             record = self._records[record]
         if record.should_retry(value):
+            error = value.err()  # Get the exception instance.
+            logger.warning(
+                "Error processing record %s: Retrying execution.",
+                record.id,
+                exc_info=error,  # This includes the traceback.
+            )
             record.increate_attempt()
             self._delay_queue.enqueue(Invoke(record.id), record.next_retry_delay())
             return []