diff --git a/image_decode_cv2.py b/image_decode_cv2.py
index 70bcc37..0e49b2e 100644
--- a/image_decode_cv2.py
+++ b/image_decode_cv2.py
@@ -49,7 +49,7 @@ class ImageDecoder(PyOperator):
             raise RuntimeError(err)
 
         rgb_cv_image = cv2.cvtColor(bgr_cv_image, cv2.COLOR_BGR2RGB)
-        return ndarray_utils.from_ndarray(rgb_cv_image, 'RGB')
+        return Image(rgb_cv_image, 'RGB')
 
     @property
     def shared_type(self):