@@ -103,6 +103,9 @@ def usage():
103
103
parser .add_argument ('--zarr' ,
104
104
action = 'store_true' ,
105
105
help = 'Output will be wrote in zarr' )
106
+ parser .add_argument ('--unraw' ,
107
+ action = 'store_true' ,
108
+ help = 'Load unraw data' )
106
109
parser .add_argument ('--blank_period' ,
107
110
type = int ,
108
111
default = 0 ,
@@ -114,12 +117,13 @@ def usage():
114
117
config = yaml_load (stream )
115
118
if args .correspondance_in is not None and not exists (args .correspondance_in ):
116
119
args .correspondance_in = None
117
- return config , args .save_correspondance_and_stop , args .correspondance_in , args .correspondance_out , args .blank_period , args .zarr
120
+ return config , args .save_correspondance_and_stop , args .correspondance_in , args .correspondance_out ,\
121
+ args .blank_period , args .zarr , not args .unraw
118
122
119
123
120
124
if __name__ == '__main__' :
121
- CONFIG , SAVE_STOP , CORRESPONDANCES_IN , CORRESPONDANCES_OUT , BLANK_PERIOD , ZARR = usage ()
122
-
125
+ CONFIG , SAVE_STOP , CORRESPONDANCES_IN , CORRESPONDANCES_OUT , BLANK_PERIOD , ZARR , RAW = usage ()
126
+ print ( RAW )
123
127
# Create output directory
124
128
SAVE_DIR = CONFIG ['PATHS' ].get ('SAVE_DIR' , None )
125
129
if SAVE_DIR is not None and not exists (SAVE_DIR ):
@@ -189,15 +193,15 @@ if __name__ == '__main__':
189
193
logger .info ('Longer track saved have %d obs' , CORRESPONDANCES .nb_obs_by_tracks .max ())
190
194
logger .info ('The mean length is %d observations before filtering' , CORRESPONDANCES .nb_obs_by_tracks .mean ())
191
195
192
- CORRESPONDANCES .get_unused_data ().write_file (path = SAVE_DIR , filename = '%(path)s/%(sign_type)s_untracked.nc' , zarr_flag = ZARR )
196
+ CORRESPONDANCES .get_unused_data (raw_data = RAW ).write_file (path = SAVE_DIR , filename = '%(path)s/%(sign_type)s_untracked.nc' , zarr_flag = ZARR )
193
197
194
198
SHORT_CORRESPONDANCES = CORRESPONDANCES ._copy ()
195
199
SHORT_CORRESPONDANCES .shorter_than (size_max = NB_OBS_MIN )
196
200
197
201
CORRESPONDANCES .longer_than (size_min = NB_OBS_MIN )
198
202
199
- FINAL_EDDIES = CORRESPONDANCES .merge ()
200
- SHORT_TRACK = SHORT_CORRESPONDANCES .merge ()
203
+ FINAL_EDDIES = CORRESPONDANCES .merge (raw_data = RAW )
204
+ SHORT_TRACK = SHORT_CORRESPONDANCES .merge (raw_data = RAW )
201
205
202
206
# We flag obs
203
207
if CORRESPONDANCES .virtual :
0 commit comments