diff --git a/video_prediction_tools/main_scripts/main_preprocess_data_step1.py b/video_prediction_tools/main_scripts/main_preprocess_data_step1.py
index 0289c3f5ddb8d7bd35cb33d4b31692166de8b1b2..4e26407a8896ad7778fb808c557a4ee00690ef7e 100755
--- a/video_prediction_tools/main_scripts/main_preprocess_data_step1.py
+++ b/video_prediction_tools/main_scripts/main_preprocess_data_step1.py
@@ -199,8 +199,8 @@ def main():
                 if rsync_status == 1:
                     
                    # ML 2020/06/09: workaround to get correct destination_dir obtained by the master node
-                    destination_dir = os.path.join(MetaData.get_destdir_jsontmp(tmp_dir=current_path),"pickle",years)
-                    process_data = PreprocessNcToPkl(src_dir=source_dir,target_dir=destination_dir,job_name=job,slices=slices,vars=vars)
+                    destination_dir = MetaData.get_destdir_jsontmp(tmp_dir=current_path)
+                    process_data = PreprocessNcToPkl(src_dir=source_dir,target_dir=destination_dir,year=years,job_name=job,slices=slices,vars=vars)
                     process_data()
                     #process_netCDF_in_dir(job_name=job, src_dir=source_dir, target_dir=destination_dir,slices=slices,vars=vars)