UtilitiesΒΆ Checks get_empty_result_resource() get_empty_result_dataset() get_empty_result_time_based() get_empty_result_time_based_scope() complete_result_resource() complete_result_resource_pass_fail() field_coverage_check() field_quality_check() coherent_dates_check() ReservoirSampler ReservoirSampler.process() Codelists get_document_type_section_mapping() get_identifier_scheme_codelist() get_language_codelist() get_media_type_codelist() get_ocid_prefix_codelist() Currency Converter bootstrap() import_data() interpolation_closest() interpolation_linear() extrapolation_closest_rate() convert() Getter get_amount() parse_datetime() parse_date() deep_has() deep_get() get_values() Services encode() decode() consume() publish() Json Json.dumps() get_cursor() commit() rollback() state state.IN_PROGRESS state.OK phase phase.CONTRACTING_PROCESS phase.DATASET phase.TIME_VARIANCE phase.CHECKED phase.DELETED initialize_dataset_state() update_dataset_state() initialize_items_state() update_items_state() get_processed_items_count() get_total_items_count() get_dataset_progress() Settings Steps Steps.FIELD_COVERAGE Steps.FIELD_QUALITY Steps.COMPILED_RELEASE Steps.DATASET Steps.TIME_BASED Steps.REPORT Workers is_step_required() process_items() finish_callback()