Replicate BMDTransformer.clean_column_names logic.

AUC via sklearn.

Compute Moran's I spatial autocorrelation using k-nearest neighbours. Parameters ---------- values : 1-D array of the variable of interes

Nagelkerke R² (1991) from a fitted statsmodels Logit model.

Convert a filename in a path to snake_case. Args: path: Path with filename Returns: Path with snake_case fil

Creates a distinct lookup table from columns and saves it locally (temporary use during processing). Args: con: DuckDB connection or a wr

Create minimal fertilizer schema with defaults.

Write a valid parquet file to the fetcher's output directory.

Download .rds file from storage to a temporary local file. Args: rds_path: Relative path to .rds file in storage

Emergency resource cleanup when approaching memory limits.

Enrich subsidy tables with field UUIDs from matching FVM marker fields. This method performs spatial matching between subsidy fields

Extract CVR numbers from a table using flexible column detection. Tries multiple possible column names that might contain CVR numbers.

Extract the GPKG file from the downloaded ZIP. Args: zip_path: Path to the ZIP file output_dir: Directory to

Fetch data for a specific DAGI layer from the DAWA API. Args: session: aiohttp client session layer_name: Na

Fetch monthly-aggregated data for one climate parameter by iterating month-by-month. This avoids the 10 000-feature cap on the DMI en

Fetch all available BNBO status data from the WFS service. This method sets up an HTTP session with the appropriate SSL context,

Fetch data and metadata for a specific DST table. Args: table_id (str): DST table identifier Returns:

Find a column from a list of candidate names.

Find the latest Silver layer file for a given table type.

Format a default value for SQL. Args: default_value: The default value data_type: The target data type Retur

Get the path to fertilizer data from the fertiliser directory structure. Args: target_year: Optional target year to matc

Get metadata for a file or folder. Args: file_id: ID of the file or folder Returns: File metadata as a dicti

Get area statistics from a table.

Initialize known high-volume herds with optimized settings.

Load the Kemidata CSV export from storage directly into a DuckDB table. The bronze stage stores CSV exports via StorageAccess. Downl

Load a single FVM silver dataset.

Load high-volume herds configuration from cloud storage.

Load problematic herds from persistent storage (cloud storage).

Materialise a synthetic enhanced-pesticide table for summary-query tests. Each row is a dict with the columns the BMD-enhanced summary query

Make an authenticated request to the DMI API with error handling and retry logic

Create StorageAccess with in-memory file storage mock.

Generate per-company pesticide detail files. Returns count of files written.

Perform spatial join between fields and kommuner for PFAS analysis.

Put this pipeline first and clear cached sibling pipeline modules.

Raise when GLRCHR returns a service-level error inside a SOAP 200 response.

Read bronze data from storage using the latest timestamped directory. Args: dataset: The name of the dataset to read

Read data from storage for any stage using unified connection.

Run a BMD HTTP request with bounded timeout and retry on transient failures.

Run arbejdstilsynet main.py with given args.

Run BMD scraper main.py with given args.

Safely access nested dictionary values with null checks. Args: data: Dictionary to access *keys: Sequence of

Sanitize a folder name to be used as a dataset name. Args: name: Raw folder name Returns: Sanitized dataset

Save attributes data to parquet using DuckDB streaming approach.

Save a dataframe locally for testing.

Return true when a failed Kemidata download may succeed in smaller slices.

DISABLE validation for Stage 1 Soil Types - testing override mechanism.

Validate geometries are within Denmark bounds (EPSG:25832).

Validate P-number format. Args: pnumber: P-number to validate Returns: True if valid, False otherwi

Add an NH3 sub-source emission to this category.

Analyze a geometry and extract key metrics using DuckDB-spatial. This method calculates width, height, area, grid alignment, and ver

Apply CLI filtering for matrix job processing. This method modifies the year lists based on CLI parameters to enable process

Beregn den samlede CO2e-udledning fra alle indkøbte kvæg. Implements formulas from Markdown page 19. Args: purchased_animal_grou

* Calculate buffer size based on zoom level

Beregner tørstof i afgrøderester over jorden (A_over) i kg ts/ha. Formel: A_over = ((T + H_u) * S + I) * k_græs + (X1_val - 1) * H_f * T + X

Beregner tørstof i afgrøderester under jorden (A_under) i kg ts/ha. Formel: A_under = (T + H_u + ((T + H_u) * S + I) * k_græs) * F The C#

Beregner kg CO2 fra kalkning for hele bedriften pr år. Formel: CO2_bedrift = (A_total_kalket_areal * S_CaCO3_pr_ha_aar / M_CaCO3) * M_C

Fordeler bedriftens samlede CO2-bidrag fra kalk ligeligt ud på en specifik mark. Formel: CO2_mark = CO2_bedrift * (A_mark_areal / A_tota

Beregner CO2e fra N i afgrøderester pr. ha for hovedafgrøder. F_Omlæg (1/o_omlaegningsfrekvens) applies to N_over for ploughed perennials.

Beregner CO2e fra kulstofbalancen for en mark. Args: r_relativ_faktor (int): Indikerer om afgrøden skal relativeres til DK gennemsni

Calculate a checksum for file content. Args: content: File content as bytes algorithm: Hash algorithm to use (default: sha256)

Calculate complete emissions for a farm for a given year. Args: cvr: Danish company registration number (8 digits)

Calculate a checksum for a file. Args: file_path: Path to the file algorithm: Hash algorithm to use (default: sha256) Return

Beregner N i afgrøderester pr. ha. Returns N_A_over_kg_n_ha, N_A_under_kg_n_ha, N_total_afgroederester_kg_n_ha

Beregner produktaftrykket (P_a) for en given afgrøde (target_afgroede_navn) baseret på en liste af marker (fields_data). P_a = Sum(CO2e_

Convert CH4 mass to CO2 equivalent using IPCC AR5 GWP. Args: ch4_kg (float): Mass of CH4 in kg config: Optional ConfigLoader

Clean up all temporary files and directories.

Clean up resources and save cache.

Explicitly clears the data buffer if needed before finalization.

Close the DuckDB connection.

Count parquet rows using footer metadata instead of scanning full files.

Create sample spatial data for demonstration.

Create a legacy Zeep SOAP client with UsernameToken-only authentication.

Mock create_soap_envelope_template function.

Convert degrees to approximate meters for Denmark latitude. Args: degrees: Distance in degrees Returns: Approximate dis

Detect available years for all data sources. Returns: Dictionary mapping data source names to lists of available years

Discover all known FVM WFS layer years from live WFS capabilities. Args: wfs_url: Base WFS endpoint URL. timeout_s: Request

Drop a table if it exists.

Get the current elapsed time without exiting the context

* Expand bounds by buffer amount