diff --git a/pippin/dataprep.py b/pippin/dataprep.py
index 419d9506..ec42ea8e 100644
--- a/pippin/dataprep.py
+++ b/pippin/dataprep.py
@@ -50,6 +50,7 @@ def __init__(self, name, output_dir, config, options, global_config, dependencie
         self.output_info = os.path.join(self.output_dir, f"{self.genversion}.YAML")
         self.output["genversion"] = self.genversion
         self.opt_setpkmjd = options.get("OPT_SETPKMJD", 16)
+        self.photflag_mskrej = options.get("PHOTFLAG_MSKREJ", 1016)
         self.output["data_path"] = self.data_path
         self.output["photometry_dirs"] = [get_output_loc(self.raw_dir)]
         self.output["sim_folders"] = [get_output_loc(self.raw_dir)]
@@ -117,7 +118,7 @@ def __init__(self, name, output_dir, config, options, global_config, dependencie
      PRIVATE_DATA_PATH = '{data_path}'
      VERSION_PHOTOMETRY = '{genversion}'
 
-     PHOTFLAG_MSKREJ   = 1016 !PHOTFLAG eliminate epoch that has errors, not LC 
+     PHOTFLAG_MSKREJ   = {photflag_mskrej} !PHOTFLAG eliminate epoch that has errors, not LC 
 
      {photflag}
      {cutwin_snr_nodetect}
@@ -154,7 +155,7 @@ def _run(self):
         photflag = f"PHOTFLAG_DETECT = {val_p}" if val_p else ""
         cutwin = f"CUTWIN_SNR_NODETECT = {val_c}" if val_c else ""
         command_string = self.clump_command.format(
-            genversion=self.genversion, data_path=self.data_path, opt_setpkmjd=self.opt_setpkmjd, photflag=photflag, cutwin_snr_nodetect=cutwin
+            genversion=self.genversion, data_path=self.data_path, opt_setpkmjd=self.opt_setpkmjd, photflag=photflag, cutwin_snr_nodetect=cutwin, photflag_mskrej=self.photflag_mskrej
         )
         header_dict = {
                 "job-name": self.job_name,