diff --git a/src/schemas.py b/src/schemas.py
index d9f5358..6e46888 100644
--- a/src/schemas.py
+++ b/src/schemas.py
@@ -49,7 +49,7 @@ class IngestInputSchema(ma.Schema):
 
 
 class EncodeInputSchema(ma.Schema):
-    inputNeighbour = fields.UUID(required=False)
+    inputNeighbour = fields.UUID(required=False, allow_none=True)
     outputNeighbours = fields.List(fields.UUID(), required=False)
     bitrate = fields.Integer(required=False)
     width = fields.Integer(required=False)
@@ -59,7 +59,7 @@ class EncodeInputSchema(ma.Schema):
 
 
 class RestreamInputSchema(ma.Schema):
-    inputNeighbour = fields.UUID(required=False)
+    inputNeighbour = fields.UUID(required=False, allow_none=True)
     outputURLs = fields.List(fields.String(), required=False)
     x = fields.Integer(required=True)
     y = fields.Integer(required=True)