diff --git a/fluster/decoders/gstreamer.py b/fluster/decoders/gstreamer.py
index 5284c2e6..11d1928f 100644
--- a/fluster/decoders/gstreamer.py
+++ b/fluster/decoders/gstreamer.py
@@ -33,7 +33,7 @@
 )
 
 PIPELINE_TPL = "{} --no-fault filesrc location={} ! {} ! {} ! {} ! {} {}"
-PIPELINE_TPL_FLU_H266_DEC = "{} --no-fault filesrc location={} ! {} ! {} ! {} {}"
+PIPELINE_TPL_FLU_H266_DEC = "{} --no-fault filesrc location={} {} ! {} ! {} ! {} {}"
 
 
 @lru_cache(maxsize=None)
@@ -791,9 +791,11 @@ def gen_pipeline(
     ) -> str:
         caps = f"{self.caps} ! videoconvert dither=none ! video/x-raw,format={output_format_to_gst(output_format)}"
         output = f"location={output_filepath}" if output_filepath else ""
+
         return PIPELINE_TPL_FLU_H266_DEC.format(
             self.cmd,
             input_filepath,
+            "! h266parse " if gst_element_exists("h266parse") else "",
             self.decoder_bin,
             caps,
             self.sink,