Index

A

abort() (adapt.persistence.objects.ObjectStore method) acquire_existing() (adapt.runtime.acquire.StoreAcquirer method) acquire_file() (adapt.runtime.acquire.StoreAcquirer method) adapt.api.domain module adapt.api.selection module adapt.cli module adapt.configuration.schemas.internal module adapt.configuration.schemas.module_resolver module adapt.configuration.schemas.param module adapt.configuration.schemas.resolve module adapt.configuration.schemas.user module adapt.consumers.live.dashboard module adapt.contracts.analysis module adapt.contracts.grid module adapt.contracts.pipeline module adapt.contracts.projection module adapt.contracts.segmentation module adapt.contracts.time module adapt.contracts.tracking module adapt.execution.graph.builder module adapt.execution.graph.executor module adapt.execution.graph.node module adapt.execution.module_registry module adapt.modules.acquisition.module module adapt.modules.analysis.module module adapt.modules.detection.module module adapt.modules.ingest.module module adapt.modules.projection.module module adapt.modules.tracking.module module adapt.persistence.collection_catalog module

adapt.persistence.errors module adapt.persistence.execution_history module adapt.persistence.objects module adapt.persistence.output_router module adapt.persistence.products module adapt.persistence.store module adapt.persistence.store_registry module adapt.persistence.track_store module adapt.runtime.acquire module adapt.runtime.orchestrator module adapt.runtime.postprocessor module adapt.runtime.processor module adapt.utils.time module adapt.visualization.plotter module AdaptDashboard (class in adapt.consumers.live.dashboard) add_lineage() (adapt.persistence.collection_catalog.Catalog method) adjacency_min_touching_boundary_pixels (adapt.configuration.schemas.internal.InternalAnalyzerConfig attribute) (adapt.configuration.schemas.param.AnalyzerConfig attribute) ages (adapt.modules.detection.module.CarriedLabels attribute) alphabet (adapt.configuration.schemas.internal.InternalTrackerConfig.InternalCellUidConfig attribute) (adapt.configuration.schemas.param.TrackerConfig.CellUidConfig attribute) AlreadyInitializedError, [1] analyzer (adapt.configuration.schemas.internal.InternalConfig attribute) (adapt.configuration.schemas.param.ParamConfig attribute) (adapt.configuration.schemas.user.UserConfig attribute) AnalyzerConfig (class in adapt.configuration.schemas.param) annotate() (adapt.api.store_client.StoreClient method) annotations() (adapt.api.store_client.StoreClient method) artifact_id (adapt.persistence.collection_catalog.ArtifactRecord attribute) (adapt.persistence.objects.ObjectWriteHandle attribute) artifact_type (adapt.persistence.collection_catalog.ArtifactRecord attribute) (adapt.persistence.objects.ArtifactMeta attribute) ArtifactMeta (class in adapt.persistence.objects) ArtifactRecord (class in adapt.persistence.collection_catalog) artifacts() (adapt.api.store_client.StoreClient method) assert_analysis_output() (in module adapt.contracts.analysis) assert_cell_adjacency() (in module adapt.contracts.analysis) assert_cell_events() (in module adapt.contracts.tracking) assert_gridded() (in module adapt.contracts.grid) assert_projected() (in module adapt.contracts.projection) assert_segmented() (in module adapt.contracts.segmentation) assert_time_normalized() (in module adapt.contracts.time) assert_tracked_cells() (in module adapt.contracts.tracking) AwsNexradDownloader (class in adapt.modules.acquisition.module)

B

base_dir (adapt.configuration.schemas.internal.InternalConfig attribute) (adapt.configuration.schemas.user.UserConfig attribute) basemap_alpha (adapt.configuration.schemas.internal.InternalVisualizationConfig attribute) (adapt.configuration.schemas.param.VisualizationConfig attribute)

begin() (adapt.persistence.objects.ObjectStore method) begin_run() (adapt.persistence.store_registry.StoreRegistry method) build() (adapt.execution.graph.builder.GraphBuilder method)

C

carried_exempt_size_filter (adapt.configuration.schemas.internal.InternalSegmenterConfig attribute) (adapt.configuration.schemas.param.SegmenterConfig attribute) (adapt.configuration.schemas.user.UserSegmenterConfig attribute) CarriedLabels (class in adapt.modules.detection.module) Catalog (class in adapt.persistence.collection_catalog) cell_threshold (adapt.configuration.schemas.internal.InternalTrackerConfig attribute) (adapt.configuration.schemas.param.TrackerConfig attribute) cell_uid (adapt.api.domain.Track attribute) (adapt.configuration.schemas.internal.InternalTrackerConfig attribute) (adapt.configuration.schemas.param.TrackerConfig attribute) cells (adapt.api.domain.ScanBundle attribute) cells() (adapt.api.store_client.StoreClient method) cells_at_scan() (adapt.api.store_client.StoreClient method) CellTracker (class in adapt.modules.tracking.module) check_cell_adjacency() (in module adapt.contracts.analysis) check_cell_events() (in module adapt.contracts.tracking) check_cell_stats() (in module adapt.contracts.analysis) check_grid_ds_2d() (in module adapt.contracts.grid) check_projected_ds() (in module adapt.contracts.projection) check_seed_carry() (in module adapt.contracts.segmentation) check_segmented_ds() (in module adapt.contracts.segmentation) check_time_normalized() (in module adapt.contracts.time) check_tracked_cells() (in module adapt.contracts.tracking) checksum_sha256 (adapt.persistence.collection_catalog.ArtifactRecord attribute) children_of() (adapt.persistence.collection_catalog.Catalog method) clear() (adapt.execution.module_registry.ModuleRegistry method) close() (adapt.api.domain.ScanRaster method) (adapt.api.store_client.StoreClient method) (adapt.persistence.store.Collection method) (adapt.persistence.store.Store method) (adapt.persistence.track_store.TrackStore method) close_all() (adapt.persistence.store_registry.StoreRegistry class method) close_store() (adapt.runtime.orchestrator.PipelineOrchestrator method) closing_radius (adapt.configuration.schemas.internal.InternalSegmenterConfig attribute) (adapt.configuration.schemas.param.SegmenterConfig attribute) (adapt.configuration.schemas.user.UserSegmenterConfig attribute)

coerce_numeric_fields() (adapt.configuration.schemas.user.UserConfig class method) coerce_z_level() (adapt.configuration.schemas.user.UserGlobalConfig class method) coerce_z_level_to_float() (adapt.configuration.schemas.param.GlobalConfig class method) Collection (class in adapt.api.domain) (class in adapt.persistence.store) collection() (adapt.persistence.store.Store method) collection_id (adapt.api.domain.Collection attribute) (adapt.api.domain.Run attribute) (adapt.api.domain.Scan attribute) (adapt.persistence.store_registry.RunStart attribute) collections() (adapt.api.store_client.StoreClient method) columns (adapt.persistence.products.TableDeclaration attribute) commit() (adapt.persistence.objects.ObjectStore method) complete_scans() (adapt.persistence.collection_catalog.Catalog method) compression (adapt.configuration.schemas.internal.InternalOutputConfig attribute) (adapt.configuration.schemas.param.OutputConfig attribute) config_hash (adapt.api.domain.Run attribute) (adapt.persistence.store_registry.RunStart attribute) config_json (adapt.persistence.store_registry.RunStart attribute) console_level (adapt.configuration.schemas.internal.InternalLoggingConfig attribute) console_logs (adapt.configuration.schemas.internal.InternalLoggingConfig attribute) ContractViolation conv_strat_raut_params (adapt.configuration.schemas.internal.InternalSegmenterConfig attribute) (adapt.configuration.schemas.param.SegmenterConfig attribute) conv_strat_yuter_params (adapt.configuration.schemas.internal.InternalSegmenterConfig attribute) (adapt.configuration.schemas.param.SegmenterConfig attribute) coord_names (adapt.configuration.schemas.internal.InternalGlobalConfig attribute) (adapt.configuration.schemas.param.GlobalConfig attribute) (adapt.configuration.schemas.user.UserGlobalConfig attribute) CoordNamesConfig (class in adapt.configuration.schemas.param) core_field_threshold (adapt.configuration.schemas.internal.InternalTrackerConfig attribute) (adapt.configuration.schemas.param.TrackerConfig attribute) create_modules() (adapt.execution.module_registry.ModuleRegistry method) current_activity() (adapt.runtime.processor.RadarProcessor method)

D

db_filename_pattern (adapt.configuration.schemas.internal.InternalProcessorConfig attribute) decisions() (adapt.modules.detection.module.RadarCellSegmenter method) (adapt.modules.tracking.module.CellTracker method) deep_merge() (in module adapt.configuration.schemas.resolve) dependencies (adapt.execution.graph.node.Node attribute) dependents (adapt.execution.graph.node.Node attribute)

downloader (adapt.configuration.schemas.internal.InternalConfig attribute) (adapt.configuration.schemas.param.ParamConfig attribute) (adapt.configuration.schemas.user.UserConfig attribute) DownloaderConfig (class in adapt.configuration.schemas.param) dpi (adapt.configuration.schemas.internal.InternalVisualizationConfig attribute) (adapt.configuration.schemas.param.VisualizationConfig attribute)

E

enabled (adapt.configuration.schemas.internal.InternalLoggingConfig attribute) (adapt.configuration.schemas.internal.InternalVisualizationConfig attribute) (adapt.configuration.schemas.param.VisualizationConfig attribute) end_time (adapt.api.domain.Scan attribute) (adapt.configuration.schemas.internal.InternalDownloaderConfig attribute) (adapt.configuration.schemas.param.DownloaderConfig attribute) (adapt.configuration.schemas.user.UserConfig attribute) (adapt.configuration.schemas.user.UserDownloaderConfig attribute) ended_at (adapt.api.domain.Run attribute) ensure_collection_location() (adapt.persistence.store_registry.StoreRegistry method)

environment_json (adapt.persistence.store_registry.RunStart attribute) exclude_fields (adapt.configuration.schemas.internal.InternalAnalyzerConfig attribute) (adapt.configuration.schemas.param.AnalyzerConfig attribute) (adapt.configuration.schemas.user.UserAnalyzerConfig attribute) (adapt.configuration.schemas.user.UserConfig attribute) exclude_modules (adapt.configuration.schemas.internal.InternalConfig attribute) extensions (adapt.configuration.schemas.internal.InternalConfig attribute) (adapt.configuration.schemas.user.UserConfig attribute) extract() (adapt.modules.analysis.module.RadarCellAnalyzer method) extract_adjacency() (adapt.modules.analysis.module.RadarCellAnalyzer method)

F

feature_detection_params (adapt.configuration.schemas.internal.InternalSegmenterConfig attribute) (adapt.configuration.schemas.param.SegmenterConfig attribute) field_map (adapt.configuration.schemas.internal.InternalReaderConfig attribute) (adapt.configuration.schemas.param.ReaderConfig attribute) fields (adapt.configuration.schemas.internal.InternalReaderConfig attribute) (adapt.configuration.schemas.param.ReaderConfig attribute) figsize (adapt.configuration.schemas.internal.InternalVisualizationConfig attribute) (adapt.configuration.schemas.param.VisualizationConfig attribute) file_format (adapt.configuration.schemas.internal.InternalReaderConfig attribute) (adapt.configuration.schemas.param.ReaderConfig attribute) filter_by_size (adapt.configuration.schemas.internal.InternalSegmenterConfig attribute) (adapt.configuration.schemas.param.SegmenterConfig attribute) (adapt.configuration.schemas.user.UserSegmenterConfig attribute) FilterSpec (class in adapt.api.selection) finalize_run() (adapt.persistence.execution_history.StoreExecutionHistory method) (adapt.persistence.store_registry.StoreRegistry method) find_artifact() (adapt.persistence.collection_catalog.Catalog method) find_artifact_by_scan() (adapt.persistence.collection_catalog.Catalog method)

find_by_source_uri() (adapt.persistence.collection_catalog.Catalog method) first_seen (adapt.api.domain.Track attribute) first_seen_after (adapt.api.selection.FilterSpec attribute) first_seen_before (adapt.api.selection.FilterSpec attribute) flags (adapt.configuration.schemas.internal.InternalFlowParamsConfig attribute) (adapt.configuration.schemas.param.FlowParamsConfig attribute) flow_params (adapt.configuration.schemas.internal.InternalProjectorConfig attribute) (adapt.configuration.schemas.param.ProjectorConfig attribute) (adapt.configuration.schemas.user.UserProjectorConfig attribute) flow_scale (adapt.configuration.schemas.internal.InternalVisualizationConfig attribute) (adapt.configuration.schemas.param.VisualizationConfig attribute) flow_subsample (adapt.configuration.schemas.internal.InternalVisualizationConfig attribute) (adapt.configuration.schemas.param.VisualizationConfig attribute) FlowParamsConfig (class in adapt.configuration.schemas.param) fold_legacy_closing_kernel() (adapt.configuration.schemas.user.UserSegmenterConfig class method) fold_legacy_seed_carry() (adapt.configuration.schemas.user.UserSegmenterConfig class method) freeze() (adapt.persistence.products.SchemaLedger method) from_scan_iso() (in module adapt.utils.time) frozen() (adapt.persistence.products.SchemaLedger method)

G

get() (adapt.execution.module_registry.ModuleRegistry method) get_artifact() (adapt.persistence.collection_catalog.Catalog method) get_cell_events() (adapt.persistence.track_store.TrackStore method) get_cell_tracks() (adapt.persistence.track_store.TrackStore method) get_cells_by_scan() (adapt.persistence.track_store.TrackStore method) get_collection() (adapt.persistence.store_registry.StoreRegistry method) get_historical_progress() (adapt.modules.acquisition.module.AwsNexradDownloader method) get_instance() (adapt.persistence.store_registry.StoreRegistry class method) get_lat_lon() (adapt.modules.analysis.module.RadarCellAnalyzer static method) get_run() (adapt.persistence.store_registry.StoreRegistry method) get_scan() (adapt.persistence.collection_catalog.Catalog method) get_track_history() (adapt.persistence.track_store.TrackStore method) global_ (adapt.configuration.schemas.internal.InternalConfig attribute) (adapt.configuration.schemas.param.ParamConfig attribute) (adapt.configuration.schemas.user.UserConfig attribute)

GlobalConfig (class in adapt.configuration.schemas.param) granularity (adapt.persistence.products.TableDeclaration attribute) GraphBuilder (class in adapt.execution.graph.builder) GraphExecutor (class in adapt.execution.graph.executor) grid_limits (adapt.configuration.schemas.internal.InternalRegridderConfig attribute) (adapt.configuration.schemas.param.RegridderConfig attribute) (adapt.configuration.schemas.user.UserConfig attribute) (adapt.configuration.schemas.user.UserRegridderConfig attribute) grid_shape (adapt.configuration.schemas.internal.InternalRegridderConfig attribute) (adapt.configuration.schemas.param.RegridderConfig attribute) (adapt.configuration.schemas.user.UserConfig attribute) (adapt.configuration.schemas.user.UserRegridderConfig attribute) growth_max_km (adapt.configuration.schemas.internal.InternalTrackerConfig attribute) (adapt.configuration.schemas.param.TrackerConfig attribute) growth_size_km (adapt.configuration.schemas.internal.InternalTrackerConfig attribute) (adapt.configuration.schemas.param.TrackerConfig attribute)

H

h_maxima (adapt.configuration.schemas.internal.InternalSegmenterConfig attribute) (adapt.configuration.schemas.param.SegmenterConfig attribute) (adapt.configuration.schemas.user.UserSegmenterConfig attribute)

heading_weight (adapt.configuration.schemas.internal.InternalTrackerConfig attribute) (adapt.configuration.schemas.param.TrackerConfig attribute)

I

identity_intensity_weight (adapt.configuration.schemas.internal.InternalTrackerConfig attribute) (adapt.configuration.schemas.param.TrackerConfig attribute) identity_score_margin (adapt.configuration.schemas.internal.InternalTrackerConfig attribute) (adapt.configuration.schemas.param.TrackerConfig attribute) index_columns (adapt.persistence.products.TableDeclaration attribute) infer_historical_mode_from_times() (adapt.configuration.schemas.user.UserConfig method) init_store() (in module adapt.persistence.store) inputs (adapt.execution.graph.node.Node attribute) InternalAnalyzerConfig (class in adapt.configuration.schemas.internal) InternalConfig (class in adapt.configuration.schemas.internal) InternalCoordNamesConfig (class in adapt.configuration.schemas.internal) InternalDownloaderConfig (class in adapt.configuration.schemas.internal) InternalFlowParamsConfig (class in adapt.configuration.schemas.internal) InternalGlobalConfig (class in adapt.configuration.schemas.internal) InternalLoggingConfig (class in adapt.configuration.schemas.internal)

InternalOutputConfig (class in adapt.configuration.schemas.internal) InternalProcessorConfig (class in adapt.configuration.schemas.internal) InternalProjectorConfig (class in adapt.configuration.schemas.internal) InternalReaderConfig (class in adapt.configuration.schemas.internal) InternalRegridderConfig (class in adapt.configuration.schemas.internal) InternalSegmenterConfig (class in adapt.configuration.schemas.internal) InternalTrackerConfig (class in adapt.configuration.schemas.internal) InternalTrackerConfig.InternalCellUidConfig (class in adapt.configuration.schemas.internal) InternalVisualizationConfig (class in adapt.configuration.schemas.internal) is_acquired() (adapt.runtime.acquire.StoreAcquirer method) is_empty() (adapt.api.selection.FilterSpec method) is_historical_complete() (adapt.modules.acquisition.module.AwsNexradDownloader method) is_pipeline_running() (adapt.api.store_client.StoreClient method) iterations (adapt.configuration.schemas.internal.InternalFlowParamsConfig attribute) (adapt.configuration.schemas.param.FlowParamsConfig attribute)

J

json_logs (adapt.configuration.schemas.internal.InternalLoggingConfig attribute)

L

labels (adapt.modules.detection.module.CarriedLabels attribute) last_seen (adapt.api.domain.Track attribute) latent_scans (adapt.configuration.schemas.internal.InternalTrackerConfig attribute) (adapt.configuration.schemas.param.TrackerConfig attribute) latest_files (adapt.configuration.schemas.internal.InternalDownloaderConfig attribute) (adapt.configuration.schemas.param.DownloaderConfig attribute) (adapt.configuration.schemas.user.UserConfig attribute) (adapt.configuration.schemas.user.UserDownloaderConfig attribute) latest_minutes (adapt.configuration.schemas.internal.InternalDownloaderConfig attribute) (adapt.configuration.schemas.param.DownloaderConfig attribute) (adapt.configuration.schemas.user.UserConfig attribute) (adapt.configuration.schemas.user.UserDownloaderConfig attribute) latest_run() (adapt.api.store_client.StoreClient method) (adapt.persistence.store_registry.StoreRegistry method) level (adapt.configuration.schemas.internal.InternalLoggingConfig attribute) (adapt.configuration.schemas.param.LoggingConfig attribute)

levels (adapt.configuration.schemas.internal.InternalFlowParamsConfig attribute) (adapt.configuration.schemas.param.FlowParamsConfig attribute) lifetime_max_s (adapt.api.selection.FilterSpec attribute) lifetime_min_s (adapt.api.selection.FilterSpec attribute) lifetime_s (adapt.api.domain.Track attribute) link_scan_product() (adapt.persistence.collection_catalog.Catalog method) list_artifacts() (adapt.persistence.collection_catalog.Catalog method) list_collections() (adapt.persistence.store_registry.StoreRegistry method) list_modules() (adapt.execution.module_registry.ModuleRegistry method) load_and_regrid() (adapt.modules.ingest.module.RadarDataLoader method) location_lat (adapt.api.domain.Collection attribute) location_lon (adapt.api.domain.Collection attribute) logging (adapt.configuration.schemas.internal.InternalConfig attribute) (adapt.configuration.schemas.param.ParamConfig attribute) LoggingConfig (class in adapt.configuration.schemas.param)

M

main() (in module adapt.cli) (in module adapt.consumers.live.dashboard) mark_scan_failed() (adapt.persistence.collection_catalog.Catalog method) max_acceleration_ms2 (adapt.configuration.schemas.internal.InternalTrackerConfig attribute) (adapt.configuration.schemas.param.TrackerConfig attribute) max_area_km2 (adapt.api.domain.Track attribute) max_area_max_km2 (adapt.api.selection.FilterSpec attribute) max_area_min_km2 (adapt.api.selection.FilterSpec attribute) max_cellsize_gridpoint (adapt.configuration.schemas.internal.InternalSegmenterConfig attribute) (adapt.configuration.schemas.param.SegmenterConfig attribute) (adapt.configuration.schemas.user.UserConfig attribute) (adapt.configuration.schemas.user.UserSegmenterConfig attribute) max_fetch_retries (adapt.configuration.schemas.internal.InternalDownloaderConfig attribute) (adapt.configuration.schemas.param.DownloaderConfig attribute) (adapt.configuration.schemas.user.UserConfig attribute) (adapt.configuration.schemas.user.UserDownloaderConfig attribute) max_flow_magnitude (adapt.configuration.schemas.internal.InternalProjectorConfig attribute) (adapt.configuration.schemas.param.ProjectorConfig attribute) (adapt.configuration.schemas.user.UserProjectorConfig attribute) max_history (adapt.configuration.schemas.internal.InternalProcessorConfig attribute) max_link_cost (adapt.configuration.schemas.internal.InternalTrackerConfig attribute) (adapt.configuration.schemas.param.TrackerConfig attribute) max_overlap_mismatch (adapt.configuration.schemas.internal.InternalTrackerConfig attribute) (adapt.configuration.schemas.param.TrackerConfig attribute) max_projection_steps (adapt.configuration.schemas.internal.InternalProjectorConfig attribute) (adapt.configuration.schemas.param.ProjectorConfig attribute) (adapt.configuration.schemas.user.UserConfig attribute) (adapt.configuration.schemas.user.UserProjectorConfig attribute) max_queue_size (adapt.configuration.schemas.internal.InternalDownloaderConfig attribute) (adapt.configuration.schemas.param.DownloaderConfig attribute) (adapt.configuration.schemas.user.UserDownloaderConfig attribute) max_refl_max_dbz (adapt.api.selection.FilterSpec attribute) max_refl_min_dbz (adapt.api.selection.FilterSpec attribute) max_reflectivity_dbz (adapt.api.domain.Track attribute) max_scan_gap_minutes (adapt.configuration.schemas.internal.InternalGlobalConfig attribute) (adapt.configuration.schemas.param.GlobalConfig attribute) (adapt.configuration.schemas.user.UserGlobalConfig attribute) max_speed_ms (adapt.configuration.schemas.internal.InternalTrackerConfig attribute) (adapt.configuration.schemas.param.TrackerConfig attribute) merge_overlap_threshold (adapt.configuration.schemas.internal.InternalTrackerConfig attribute) (adapt.configuration.schemas.param.TrackerConfig attribute) method (adapt.configuration.schemas.internal.InternalProjectorConfig attribute) (adapt.configuration.schemas.internal.InternalSegmenterConfig attribute) (adapt.configuration.schemas.param.ProjectorConfig attribute) (adapt.configuration.schemas.param.SegmenterConfig attribute) (adapt.configuration.schemas.user.UserProjectorConfig attribute) (adapt.configuration.schemas.user.UserSegmenterConfig attribute) metrics (adapt.configuration.schemas.internal.InternalLoggingConfig attribute) min_cellsize_gridpoint (adapt.configuration.schemas.internal.InternalSegmenterConfig attribute) (adapt.configuration.schemas.param.SegmenterConfig attribute) (adapt.configuration.schemas.user.UserConfig attribute) (adapt.configuration.schemas.user.UserSegmenterConfig attribute) min_file_size (adapt.configuration.schemas.internal.InternalDownloaderConfig attribute) (adapt.configuration.schemas.internal.InternalProcessorConfig attribute) (adapt.configuration.schemas.param.DownloaderConfig attribute) min_motion_threshold (adapt.configuration.schemas.internal.InternalProjectorConfig attribute) (adapt.configuration.schemas.param.ProjectorConfig attribute) (adapt.configuration.schemas.user.UserProjectorConfig attribute) min_radius (adapt.configuration.schemas.internal.InternalRegridderConfig attribute) (adapt.configuration.schemas.param.RegridderConfig attribute) (adapt.configuration.schemas.user.UserRegridderConfig attribute) min_reflectivity (adapt.configuration.schemas.internal.InternalVisualizationConfig attribute) (adapt.configuration.schemas.param.VisualizationConfig attribute) mode (adapt.configuration.schemas.internal.InternalConfig attribute) (adapt.configuration.schemas.internal.InternalDownloaderConfig attribute) (adapt.configuration.schemas.param.ParamConfig attribute) (adapt.configuration.schemas.user.UserConfig attribute) model_config (adapt.configuration.schemas.internal.InternalAnalyzerConfig attribute) (adapt.configuration.schemas.internal.InternalConfig attribute) (adapt.configuration.schemas.internal.InternalCoordNamesConfig attribute) (adapt.configuration.schemas.internal.InternalDownloaderConfig attribute) (adapt.configuration.schemas.internal.InternalFlowParamsConfig attribute) (adapt.configuration.schemas.internal.InternalGlobalConfig attribute) (adapt.configuration.schemas.internal.InternalLoggingConfig attribute) (adapt.configuration.schemas.internal.InternalOutputConfig attribute) (adapt.configuration.schemas.internal.InternalProcessorConfig attribute) (adapt.configuration.schemas.internal.InternalProjectorConfig attribute) (adapt.configuration.schemas.internal.InternalReaderConfig attribute) (adapt.configuration.schemas.internal.InternalRegridderConfig attribute) (adapt.configuration.schemas.internal.InternalSegmenterConfig attribute) (adapt.configuration.schemas.internal.InternalTrackerConfig attribute) (adapt.configuration.schemas.internal.InternalTrackerConfig.InternalCellUidConfig attribute) (adapt.configuration.schemas.internal.InternalVisualizationConfig attribute) (adapt.configuration.schemas.param.AnalyzerConfig attribute) (adapt.configuration.schemas.param.CoordNamesConfig attribute) (adapt.configuration.schemas.param.DownloaderConfig attribute) (adapt.configuration.schemas.param.FlowParamsConfig attribute) (adapt.configuration.schemas.param.GlobalConfig attribute) (adapt.configuration.schemas.param.LoggingConfig attribute) (adapt.configuration.schemas.param.OutputConfig attribute) (adapt.configuration.schemas.param.ParamConfig attribute) (adapt.configuration.schemas.param.ProjectorConfig attribute) (adapt.configuration.schemas.param.ReaderConfig attribute) (adapt.configuration.schemas.param.RegridderConfig attribute) (adapt.configuration.schemas.param.SegmenterConfig attribute) (adapt.configuration.schemas.param.TrackerConfig attribute) (adapt.configuration.schemas.param.TrackerConfig.CellUidConfig attribute) (adapt.configuration.schemas.param.VisualizationConfig attribute) (adapt.configuration.schemas.user.UserAnalyzerConfig attribute) (adapt.configuration.schemas.user.UserConfig attribute) (adapt.configuration.schemas.user.UserDownloaderConfig attribute) (adapt.configuration.schemas.user.UserGlobalConfig attribute) (adapt.configuration.schemas.user.UserProjectorConfig attribute) (adapt.configuration.schemas.user.UserRegridderConfig attribute) (adapt.configuration.schemas.user.UserSegmenterConfig attribute)

module adapt.api.domain adapt.api.selection adapt.cli adapt.configuration.schemas.internal adapt.configuration.schemas.module_resolver adapt.configuration.schemas.param adapt.configuration.schemas.resolve adapt.configuration.schemas.user adapt.consumers.live.dashboard adapt.contracts.analysis adapt.contracts.grid adapt.contracts.pipeline adapt.contracts.projection adapt.contracts.segmentation adapt.contracts.time adapt.contracts.tracking adapt.execution.graph.builder adapt.execution.graph.executor adapt.execution.graph.node adapt.execution.module_registry adapt.modules.acquisition.module adapt.modules.analysis.module adapt.modules.detection.module adapt.modules.ingest.module adapt.modules.projection.module adapt.modules.tracking.module adapt.persistence.collection_catalog adapt.persistence.errors adapt.persistence.execution_history adapt.persistence.objects adapt.persistence.output_router adapt.persistence.products adapt.persistence.store adapt.persistence.store_registry adapt.persistence.track_store adapt.runtime.acquire adapt.runtime.orchestrator adapt.runtime.postprocessor adapt.runtime.processor adapt.utils.time adapt.visualization.plotter module (adapt.execution.graph.node.Node attribute) module_params (adapt.configuration.schemas.internal.InternalConfig attribute) (adapt.configuration.schemas.user.UserConfig attribute) ModuleRegistry (class in adapt.execution.module_registry) modules (adapt.configuration.schemas.internal.InternalConfig attribute) (adapt.configuration.schemas.user.UserConfig attribute)

N

n_scans (adapt.api.domain.Track attribute) n_scans_min (adapt.api.selection.FilterSpec attribute) name (adapt.execution.graph.node.Node property) nan_fill_value (adapt.configuration.schemas.internal.InternalProjectorConfig attribute) (adapt.configuration.schemas.param.ProjectorConfig attribute) (adapt.configuration.schemas.user.UserProjectorConfig attribute)

Node (class in adapt.execution.graph.node) normalize_method() (adapt.configuration.schemas.user.UserProjectorConfig class method) (adapt.configuration.schemas.user.UserSegmenterConfig class method) normalize_method_name() (adapt.configuration.schemas.param.ProjectorConfig class method) normalize_method_names() (adapt.configuration.schemas.user.UserConfig class method) normalize_time_scalar() (in module adapt.utils.time)

O

object_name (adapt.persistence.collection_catalog.ArtifactRecord attribute) ObjectStore (class in adapt.persistence.objects) ObjectWriteHandle (class in adapt.persistence.objects) observation_time (adapt.persistence.collection_catalog.ArtifactRecord attribute) (adapt.persistence.objects.ArtifactMeta attribute) only_modules (adapt.configuration.schemas.internal.InternalConfig attribute) open() (adapt.persistence.store.Store class method) open_scan_raster() (adapt.api.store_client.StoreClient method) origin_type (adapt.api.domain.Track attribute) origin_types (adapt.api.selection.FilterSpec attribute) original_filename (adapt.persistence.collection_catalog.ArtifactRecord attribute) (adapt.persistence.objects.ArtifactMeta attribute)

output (adapt.configuration.schemas.internal.InternalConfig attribute) (adapt.configuration.schemas.param.ParamConfig attribute) output_dir (adapt.configuration.schemas.internal.InternalDownloaderConfig attribute) (adapt.configuration.schemas.param.DownloaderConfig attribute) (adapt.configuration.schemas.user.UserDownloaderConfig attribute) output_dirs (adapt.configuration.schemas.internal.InternalConfig attribute) output_format (adapt.configuration.schemas.internal.InternalVisualizationConfig attribute) (adapt.configuration.schemas.param.VisualizationConfig attribute) OutputConfig (class in adapt.configuration.schemas.param) outputs (adapt.execution.graph.node.Node attribute) owner_module (adapt.persistence.products.TableDeclaration attribute)

P

ParamConfig (class in adapt.configuration.schemas.param) parents_of() (adapt.persistence.collection_catalog.Catalog method) persist() (adapt.persistence.output_router.StoreOutputRouter method) pipeline_progress() (adapt.api.store_client.StoreClient method) pipeline_version (adapt.api.domain.Run attribute) (adapt.persistence.store_registry.RunStart attribute) PipelineOrchestrator (class in adapt.runtime.orchestrator) plot_from_netcdf() (adapt.visualization.plotter.RadarPlotter method) plot_reflectivity_with_cells() (adapt.visualization.plotter.RadarPlotter method) PlotConsumer (class in adapt.visualization.plotter) polarity (adapt.configuration.schemas.internal.InternalTrackerConfig attribute) (adapt.configuration.schemas.param.TrackerConfig attribute) poll_interval_sec (adapt.configuration.schemas.internal.InternalDownloaderConfig attribute) (adapt.configuration.schemas.param.DownloaderConfig attribute) (adapt.configuration.schemas.user.UserConfig attribute) (adapt.configuration.schemas.user.UserDownloaderConfig attribute) poly_n (adapt.configuration.schemas.internal.InternalFlowParamsConfig attribute) (adapt.configuration.schemas.param.FlowParamsConfig attribute) poly_sigma (adapt.configuration.schemas.internal.InternalFlowParamsConfig attribute) (adapt.configuration.schemas.param.FlowParamsConfig attribute) PostProcessor (class in adapt.runtime.postprocessor)

primary_key (adapt.persistence.products.TableDeclaration attribute) process_file() (adapt.runtime.processor.RadarProcessor method) processor (adapt.configuration.schemas.internal.InternalConfig attribute) producer (adapt.persistence.collection_catalog.ArtifactRecord attribute) (adapt.persistence.objects.ArtifactMeta attribute) progress_every (adapt.configuration.schemas.internal.InternalLoggingConfig attribute) proj_alpha (adapt.configuration.schemas.internal.InternalVisualizationConfig attribute) (adapt.configuration.schemas.param.VisualizationConfig attribute) proj_linewidth (adapt.configuration.schemas.internal.InternalVisualizationConfig attribute) (adapt.configuration.schemas.param.VisualizationConfig attribute) project() (adapt.modules.projection.module.RadarCellProjector method) projection_horizon_minutes (adapt.configuration.schemas.internal.InternalProjectorConfig attribute) (adapt.configuration.schemas.param.ProjectorConfig attribute) (adapt.configuration.schemas.user.UserProjectorConfig attribute) projection_method (adapt.configuration.schemas.user.UserConfig attribute) projector (adapt.configuration.schemas.internal.InternalConfig attribute) (adapt.configuration.schemas.param.ParamConfig attribute) (adapt.configuration.schemas.user.UserConfig attribute) ProjectorConfig (class in adapt.configuration.schemas.param) pyr_scale (adapt.configuration.schemas.internal.InternalFlowParamsConfig attribute) (adapt.configuration.schemas.param.FlowParamsConfig attribute)

Q

queue_backpressure_stats() (adapt.modules.acquisition.module.AwsNexradDownloader method) queue_resume_fraction (adapt.configuration.schemas.internal.InternalDownloaderConfig attribute) (adapt.configuration.schemas.param.DownloaderConfig attribute) (adapt.configuration.schemas.user.UserDownloaderConfig attribute)

R

radar (adapt.configuration.schemas.internal.InternalDownloaderConfig attribute) (adapt.configuration.schemas.param.DownloaderConfig attribute) (adapt.configuration.schemas.user.UserConfig attribute) (adapt.configuration.schemas.user.UserDownloaderConfig attribute) radar_variables (adapt.configuration.schemas.internal.InternalAnalyzerConfig attribute) (adapt.configuration.schemas.param.AnalyzerConfig attribute) (adapt.configuration.schemas.user.UserAnalyzerConfig attribute) (adapt.configuration.schemas.user.UserConfig attribute) RadarCellAnalyzer (class in adapt.modules.analysis.module) RadarCellProjector (class in adapt.modules.projection.module) RadarCellSegmenter (class in adapt.modules.detection.module) RadarDataLoader (class in adapt.modules.ingest.module) RadarPlotter (class in adapt.visualization.plotter) RadarProcessor (class in adapt.runtime.processor) read() (adapt.modules.ingest.module.RadarDataLoader method) reader (adapt.configuration.schemas.internal.InternalConfig attribute) (adapt.configuration.schemas.param.ParamConfig attribute) ReaderConfig (class in adapt.configuration.schemas.param) record_errors() (adapt.persistence.execution_history.StoreExecutionHistory method) record_module_execution() (adapt.persistence.store_registry.StoreRegistry method) record_modules() (adapt.persistence.execution_history.StoreExecutionHistory method) record_run_event() (adapt.persistence.store_registry.StoreRegistry method) record_warnings() (adapt.persistence.execution_history.StoreExecutionHistory method) refl_vmax (adapt.configuration.schemas.internal.InternalVisualizationConfig attribute) (adapt.configuration.schemas.param.VisualizationConfig attribute) refl_vmin (adapt.configuration.schemas.internal.InternalVisualizationConfig attribute) (adapt.configuration.schemas.param.VisualizationConfig attribute) reflectivity_var (adapt.configuration.schemas.user.UserConfig attribute) register() (adapt.execution.module_registry.ModuleRegistry method) register_artifact() (adapt.persistence.collection_catalog.Catalog method) register_collection() (adapt.persistence.store_registry.StoreRegistry method) register_external() (adapt.persistence.products.SchemaLedger method) register_scan() (adapt.persistence.collection_catalog.Catalog method) register_table_schema() (adapt.persistence.collection_catalog.Catalog method) registration_step_minutes (adapt.configuration.schemas.internal.InternalProjectorConfig attribute) (adapt.configuration.schemas.param.ProjectorConfig attribute) (adapt.configuration.schemas.user.UserProjectorConfig attribute) regrid() (adapt.modules.ingest.module.RadarDataLoader method)

regridder (adapt.configuration.schemas.internal.InternalConfig attribute) (adapt.configuration.schemas.param.ParamConfig attribute) (adapt.configuration.schemas.user.UserConfig attribute) RegridderConfig (class in adapt.configuration.schemas.param) report_callback_exception() (adapt.consumers.live.dashboard.AdaptDashboard method) repository_info() (adapt.api.store_client.StoreClient method) request_stop() (adapt.runtime.orchestrator.PipelineOrchestrator method) require() (in module adapt.contracts.pipeline) required_tags (adapt.api.selection.FilterSpec attribute) residual_weight (adapt.configuration.schemas.internal.InternalTrackerConfig attribute) (adapt.configuration.schemas.param.TrackerConfig attribute) resolve_config() (in module adapt.configuration.schemas.resolve) resolve_module_configs() (in module adapt.configuration.schemas.module_resolver) resume_run() (adapt.persistence.store_registry.StoreRegistry method) roi_func (adapt.configuration.schemas.internal.InternalRegridderConfig attribute) (adapt.configuration.schemas.param.RegridderConfig attribute) (adapt.configuration.schemas.user.UserRegridderConfig attribute) Run (class in adapt.api.domain) run() (adapt.api.store_client.StoreClient method) (adapt.execution.graph.executor.GraphExecutor method) (adapt.modules.acquisition.module.AwsNexradDownloader method) (adapt.runtime.postprocessor.PostProcessor method) (adapt.runtime.processor.RadarProcessor method) (adapt.visualization.plotter.PlotConsumer method) run_config() (adapt.api.store_client.StoreClient method) run_events() (adapt.persistence.store_registry.StoreRegistry method) run_id (adapt.api.domain.Run attribute) (adapt.api.domain.Scan attribute) (adapt.api.domain.ScanRef attribute) (adapt.api.domain.Track attribute) (adapt.configuration.schemas.internal.InternalConfig attribute) (adapt.persistence.collection_catalog.ArtifactRecord attribute) (adapt.persistence.objects.ArtifactMeta attribute) (adapt.persistence.store_registry.RunStart attribute) run_modules() (adapt.persistence.store_registry.StoreRegistry method) run_tracking_field() (adapt.api.store_client.StoreClient method) runs() (adapt.api.store_client.StoreClient method) RunStart (class in adapt.persistence.store_registry)

S

scan (adapt.api.domain.ScanBundle attribute) Scan (class in adapt.api.domain) scan_bundle() (adapt.api.store_client.StoreClient method) scan_id (adapt.api.domain.Scan attribute) (adapt.api.domain.ScanRef attribute) (adapt.persistence.collection_catalog.ArtifactRecord attribute) (adapt.persistence.objects.ArtifactMeta attribute) scan_is_complete() (adapt.persistence.collection_catalog.Catalog method) scan_products() (adapt.persistence.collection_catalog.Catalog method) scan_time (adapt.api.domain.Scan attribute) (adapt.api.domain.ScanRef attribute) scan_timeline() (adapt.api.store_client.StoreClient method) ScanBundle (class in adapt.api.domain) ScanRaster (class in adapt.api.domain) ScanRef (class in adapt.api.domain) scans() (adapt.api.store_client.StoreClient method) scans_since() (adapt.api.store_client.StoreClient method) SchemaLedger (class in adapt.persistence.products) seed_carry_frames (adapt.configuration.schemas.internal.InternalSegmenterConfig attribute) (adapt.configuration.schemas.param.SegmenterConfig attribute) (adapt.configuration.schemas.user.UserSegmenterConfig attribute) seed_carry_min_separation (adapt.configuration.schemas.internal.InternalSegmenterConfig attribute) (adapt.configuration.schemas.param.SegmenterConfig attribute) (adapt.configuration.schemas.user.UserSegmenterConfig attribute) seg_linewidth (adapt.configuration.schemas.internal.InternalVisualizationConfig attribute) (adapt.configuration.schemas.param.VisualizationConfig attribute) segment() (adapt.modules.detection.module.RadarCellSegmenter method) segmentation (adapt.api.domain.ScanBundle attribute) segmentation_method (adapt.configuration.schemas.user.UserConfig attribute) segmenter (adapt.configuration.schemas.internal.InternalConfig attribute) (adapt.configuration.schemas.param.ParamConfig attribute) (adapt.configuration.schemas.user.UserConfig attribute) SegmenterConfig (class in adapt.configuration.schemas.param) select() (adapt.api.store_client.StoreClient method) size_bytes (adapt.persistence.collection_catalog.ArtifactRecord attribute) source (adapt.configuration.schemas.internal.InternalConfig attribute) (adapt.configuration.schemas.param.ParamConfig attribute) (adapt.configuration.schemas.user.UserConfig attribute)

source_dir (adapt.configuration.schemas.internal.InternalConfig attribute) (adapt.configuration.schemas.param.ParamConfig attribute) (adapt.configuration.schemas.user.UserConfig attribute) source_file_name (adapt.api.domain.Scan attribute) source_kind (adapt.api.domain.Collection attribute) source_uri (adapt.persistence.collection_catalog.ArtifactRecord attribute) (adapt.persistence.objects.ArtifactMeta attribute) split_overlap_threshold (adapt.configuration.schemas.internal.InternalTrackerConfig attribute) (adapt.configuration.schemas.param.TrackerConfig attribute) sql() (adapt.api.store_client.StoreClient method) staging_path (adapt.persistence.objects.ObjectWriteHandle attribute) start() (adapt.runtime.orchestrator.PipelineOrchestrator method) start_time (adapt.api.domain.Scan attribute) (adapt.configuration.schemas.internal.InternalDownloaderConfig attribute) (adapt.configuration.schemas.param.DownloaderConfig attribute) (adapt.configuration.schemas.user.UserConfig attribute) (adapt.configuration.schemas.user.UserDownloaderConfig attribute) started_at (adapt.api.domain.Run attribute) status (adapt.api.domain.Run attribute) (adapt.api.domain.Scan attribute) steiner_conv_strat_params (adapt.configuration.schemas.internal.InternalSegmenterConfig attribute) (adapt.configuration.schemas.param.SegmenterConfig attribute) stop() (adapt.modules.acquisition.module.AwsNexradDownloader method) (adapt.runtime.orchestrator.PipelineOrchestrator method) (adapt.runtime.processor.RadarProcessor method) (adapt.visualization.plotter.PlotConsumer method) stopped() (adapt.modules.acquisition.module.AwsNexradDownloader method) (adapt.runtime.processor.RadarProcessor method) Store (class in adapt.persistence.store) StoreAcquirer (class in adapt.runtime.acquire) StoreClient (class in adapt.api.store_client) StoreError, [1] StoreExecutionHistory (class in adapt.persistence.execution_history) StoreOutputRouter (class in adapt.persistence.output_router) StoreRegistry (class in adapt.persistence.store_registry) suffix (adapt.persistence.objects.ObjectWriteHandle attribute)

T

table (adapt.persistence.products.TableDeclaration attribute) table() (adapt.api.store_client.StoreClient method) table_granularity() (in module adapt.persistence.products) TableDeclaration (class in adapt.persistence.products) tables() (adapt.api.store_client.StoreClient method) TableWriter (class in adapt.persistence.products) termination_type (adapt.api.domain.Track attribute) termination_types (adapt.api.selection.FilterSpec attribute) threshold_params (adapt.configuration.schemas.internal.InternalSegmenterConfig attribute) (adapt.configuration.schemas.param.SegmenterConfig attribute) time (adapt.configuration.schemas.internal.InternalCoordNamesConfig attribute) (adapt.configuration.schemas.param.CoordNamesConfig attribute) to_internal_overrides() (adapt.configuration.schemas.user.UserConfig method) to_scan_iso() (in module adapt.utils.time) to_scan_unix() (in module adapt.utils.time) to_sql_where() (adapt.api.selection.FilterSpec method) traces (adapt.configuration.schemas.internal.InternalLoggingConfig attribute)

Track (class in adapt.api.domain) track() (adapt.api.store_client.StoreClient method) (adapt.modules.tracking.module.CellTracker method) track_events() (adapt.api.store_client.StoreClient method) track_graph() (adapt.api.store_client.StoreClient method) track_history() (adapt.api.store_client.StoreClient method) track_signature_v2() (in module adapt.modules.tracking.module) tracker (adapt.configuration.schemas.internal.InternalConfig attribute) (adapt.configuration.schemas.param.ParamConfig attribute) TrackerConfig (class in adapt.configuration.schemas.param) TrackerConfig.CellUidConfig (class in adapt.configuration.schemas.param) tracking_field (adapt.configuration.schemas.internal.InternalGlobalConfig attribute) (adapt.configuration.schemas.param.GlobalConfig attribute) (adapt.configuration.schemas.user.UserGlobalConfig attribute) tracks (adapt.api.domain.ScanBundle attribute) tracks() (adapt.api.store_client.StoreClient method) TrackStore (class in adapt.persistence.track_store)

U

unregister() (adapt.execution.module_registry.ModuleRegistry method) use_basemap (adapt.configuration.schemas.internal.InternalVisualizationConfig attribute) (adapt.configuration.schemas.param.VisualizationConfig attribute) UserAnalyzerConfig (class in adapt.configuration.schemas.user) UserConfig (class in adapt.configuration.schemas.user)

UserDownloaderConfig (class in adapt.configuration.schemas.user) UserGlobalConfig (class in adapt.configuration.schemas.user) UserProjectorConfig (class in adapt.configuration.schemas.user) UserRegridderConfig (class in adapt.configuration.schemas.user) UserSegmenterConfig (class in adapt.configuration.schemas.user)

V

validate_collection() (adapt.persistence.store.Store method) visualization (adapt.configuration.schemas.internal.InternalConfig attribute) (adapt.configuration.schemas.param.ParamConfig attribute)

VisualizationConfig (class in adapt.configuration.schemas.param)

W

weighting_function (adapt.configuration.schemas.internal.InternalRegridderConfig attribute) (adapt.configuration.schemas.param.RegridderConfig attribute) (adapt.configuration.schemas.user.UserRegridderConfig attribute) width (adapt.configuration.schemas.internal.InternalTrackerConfig.InternalCellUidConfig attribute) (adapt.configuration.schemas.param.TrackerConfig.CellUidConfig attribute)

winsize (adapt.configuration.schemas.internal.InternalFlowParamsConfig attribute) (adapt.configuration.schemas.param.FlowParamsConfig attribute) write() (adapt.persistence.products.TableWriter method) write_scan() (adapt.persistence.track_store.TrackStore method)

X

x (adapt.configuration.schemas.internal.InternalCoordNamesConfig attribute) (adapt.configuration.schemas.param.CoordNamesConfig attribute)

Y

y (adapt.configuration.schemas.internal.InternalCoordNamesConfig attribute) (adapt.configuration.schemas.param.CoordNamesConfig attribute)

Z

z (adapt.configuration.schemas.internal.InternalCoordNamesConfig attribute) (adapt.configuration.schemas.param.CoordNamesConfig attribute) z_level (adapt.configuration.schemas.internal.InternalGlobalConfig attribute) (adapt.configuration.schemas.param.GlobalConfig attribute) (adapt.configuration.schemas.user.UserConfig attribute) (adapt.configuration.schemas.user.UserGlobalConfig attribute)