dartobsgen.CrocLakeSource#

class dartobsgen.CrocLakeSource(crocolake_path, dart_path, loose=True)[source]#

Bases: DataSource

Data source backed by a CrocoLake parquet database.

Parameters:

  • crocolake_path (str) – Path to the CrocoLake parquet database directory.

  • dart_path (str) – Path to the DART repository root. Used to locate observations/obs_converters/CrocoLake/convert_crocolake_obs.py.

  • loose (bool) – If True (default), write observations even when QC / error columns are missing or NaN.

__init__(crocolake_path, dart_path, loose=True)[source]#
Parameters:

  • crocolake_path (str)

  • dart_path (str)

  • loose (bool)

Methods

__init__(crocolake_path, dart_path[, loose])

check_coverage(windows)

Pre-flight check of windows against the data this source can serve.

write_obs_seq(output_file, analysis_time, ...)

Build filters from obs_types, query CrocoLake, write obs_seq file.
write_obs_seq(output_file, analysis_time, date0, date1, lat_min, lat_max, lon_min, lon_max, obs_types, obs_type_map)[source]#

Build filters from obs_types, query CrocoLake, write obs_seq file.

Observation times come from the database, so analysis_time is unused here — the window bounds carry all the timing information.

Returns True if the file was written, False if no observations were found for this window.

Parameters:
Return type:

bool