Index

A

accept_content (aodncore.pipeline.watch.CeleryConfig attribute) add() (aodncore.pipeline.files.PipelineFileCollection method) (aodncore.pipeline.PipelineFileCollection method) (aodncore.pipeline.steps.notify.NotifyList method) (aodncore.pipeline.steps.NotifyList method) (aodncore.util.IndexedSet method) add_event() (aodncore.pipeline.steps.harvest.HarvesterMap method) add_to_collection() (aodncore.pipeline.HandlerBase method) (aodncore.pipeline.handlerbase.HandlerBase method) add_watch_config() (aodncore.pipeline.log.WorkerLoggingConfigBuilder method) add_watches() (aodncore.pipeline.log.WorkerLoggingConfigBuilder method) address (aodncore.pipeline.steps.NotificationRecipient property) (aodncore.pipeline.steps.notify.NotificationRecipient property) address_validation_function (aodncore.pipeline.common.NotificationRecipientType property) (aodncore.pipeline.NotificationRecipientType property) all_addition_types (aodncore.pipeline.common.PipelineFilePublishType attribute) (aodncore.pipeline.PipelineFilePublishType attribute) all_checkable_types (aodncore.pipeline.common.PipelineFileCheckType attribute) (aodncore.pipeline.PipelineFileCheckType attribute) all_deletion_types (aodncore.pipeline.common.PipelineFilePublishType attribute) (aodncore.pipeline.PipelineFilePublishType attribute) all_events (aodncore.pipeline.steps.harvest.HarvesterMap property) all_pipeline_files (aodncore.pipeline.steps.harvest.HarvesterMap property) all_settable_types (aodncore.pipeline.common.PipelineFileCheckType attribute) (aodncore.pipeline.PipelineFileCheckType attribute) all_states (aodncore.pipeline.HandlerBase attribute) (aodncore.pipeline.handlerbase.HandlerBase attribute) all_transitions (aodncore.pipeline.HandlerBase attribute) (aodncore.pipeline.handlerbase.HandlerBase attribute) AodnBaseError, [1] aodncore module aodncore.common module aodncore.common.exceptions module aodncore.pipeline module aodncore.pipeline.common module aodncore.pipeline.config module aodncore.pipeline.configlib module aodncore.pipeline.db module aodncore.pipeline.destpath module aodncore.pipeline.exceptions module aodncore.pipeline.fileclassifier module aodncore.pipeline.files module aodncore.pipeline.geonetwork module aodncore.pipeline.handlerbase module aodncore.pipeline.log module aodncore.pipeline.schema module aodncore.pipeline.statequery module aodncore.pipeline.steps module aodncore.pipeline.steps.basestep module aodncore.pipeline.steps.check module

aodncore.pipeline.steps.harvest module aodncore.pipeline.steps.notify module aodncore.pipeline.steps.resolve module aodncore.pipeline.steps.store module aodncore.pipeline.storage module aodncore.pipeline.templates module aodncore.pipeline.watch module aodncore.table module aodncore.table.ff module aodncore.testlib module aodncore.testlib.basetest module aodncore.testlib.dummyhandler module aodncore.testlib.handlertest module aodncore.testlib.testutil module aodncore.util module aodncore.util.fileops module aodncore.util.misc module aodncore.util.process module aodncore.util.wfs module append() (aodncore.pipeline.steps.notify.NotifyList method) (aodncore.pipeline.steps.NotifyList method) application (aodncore.pipeline.watch.CeleryContext property) ARCHIVE_ONLY (aodncore.pipeline.common.PipelineFilePublishType attribute) (aodncore.pipeline.PipelineFilePublishType attribute) archive_path (aodncore.pipeline.files.PipelineFile property) (aodncore.pipeline.PipelineFile property) assert_delete_call_count() (aodncore.testlib.NullStorageBroker method) (aodncore.testlib.testutil.NullStorageBroker method) assert_delete_called() (aodncore.testlib.NullStorageBroker method) (aodncore.testlib.testutil.NullStorageBroker method) assert_delete_not_called() (aodncore.testlib.NullStorageBroker method) (aodncore.testlib.testutil.NullStorageBroker method) assert_download_call_count() (aodncore.testlib.NullStorageBroker method) (aodncore.testlib.testutil.NullStorageBroker method) assert_download_called() (aodncore.testlib.NullStorageBroker method) (aodncore.testlib.testutil.NullStorageBroker method) assert_query_call_count() (aodncore.testlib.NullStorageBroker method) (aodncore.testlib.testutil.NullStorageBroker method) assert_query_called() (aodncore.testlib.NullStorageBroker method) (aodncore.testlib.testutil.NullStorageBroker method) assert_query_not_called() (aodncore.testlib.NullStorageBroker method) (aodncore.testlib.testutil.NullStorageBroker method) assert_upload_call_count() (aodncore.testlib.NullStorageBroker method) (aodncore.testlib.testutil.NullStorageBroker method) assert_upload_called() (aodncore.testlib.NullStorageBroker method) (aodncore.testlib.testutil.NullStorageBroker method) assert_upload_not_called() (aodncore.testlib.NullStorageBroker method) (aodncore.testlib.testutil.NullStorageBroker method) assertNoException() (aodncore.testlib.basetest.BaseTestCase method) (aodncore.testlib.BaseTestCase method) AttributeNotSetError AttributeValidationError

B

basename (aodncore.pipeline.watch.IncomingFileStateManager property) BaseStepRunner (class in aodncore.pipeline.steps.basestep) BaseTestCase (class in aodncore.testlib) (class in aodncore.testlib.basetest)

broker_url (aodncore.pipeline.watch.CeleryConfig attribute) build() (aodncore.pipeline.log.WorkerLoggingConfigBuilder method) build_api_payload() (aodncore.pipeline.geonetwork.GeonetworkMetadataHandler method) build_dependency_tree() (aodncore.pipeline.steps.harvest.CsvHarvesterRunner method) build_runsheet() (aodncore.pipeline.steps.harvest.CsvHarvesterRunner method)

C

CaptureStdIO (class in aodncore.util) (class in aodncore.util.misc) celery_application (aodncore.pipeline.configlib.LazyConfigManager property) celery_routes (aodncore.pipeline.configlib.LazyConfigManager property) celery_task_id (aodncore.pipeline.HandlerBase property) (aodncore.pipeline.handlerbase.HandlerBase property) celery_task_name (aodncore.pipeline.HandlerBase property) (aodncore.pipeline.handlerbase.HandlerBase property) CeleryConfig (class in aodncore.pipeline.watch) CeleryContext (class in aodncore.pipeline.watch) check_log (aodncore.pipeline.files.PipelineFile property) (aodncore.pipeline.PipelineFile property) check_passed (aodncore.pipeline.files.PipelineFile property) (aodncore.pipeline.PipelineFile property) check_result (aodncore.pipeline.files.PipelineFile property) (aodncore.pipeline.PipelineFile property) check_type (aodncore.pipeline.files.PipelineFile property) (aodncore.pipeline.PipelineFile property) CheckResult (class in aodncore.pipeline) (class in aodncore.pipeline.common) CheckRunnerAdapter (class in aodncore.pipeline.steps.check) classify_line() (aodncore.pipeline.steps.resolve.RsyncManifestResolveRunner class method) classproperty (class in aodncore.util)

cleanup() (aodncore.util.fileops.TemporaryDirectory method) (aodncore.util.TemporaryDirectory method) clear() (aodncore.util.IndexedSet method) (aodncore.util.misc.WriteOnceOrderedDict method) (aodncore.util.WriteOnceOrderedDict method) collection_dir (aodncore.pipeline.HandlerBase property) (aodncore.pipeline.handlerbase.HandlerBase property) compare_schemas() (aodncore.pipeline.db.DatabaseInteractions method) ComplianceCheckerCheckRunner (class in aodncore.pipeline.steps.check) ComplianceCheckFailedError compliant (aodncore.pipeline.CheckResult property) (aodncore.pipeline.common.CheckResult property) config (aodncore.pipeline.HandlerBase property) (aodncore.pipeline.handlerbase.HandlerBase property) (aodncore.testlib.basetest.BaseTestCase property) (aodncore.testlib.BaseTestCase property) count() (aodncore.util.IndexedSet method) create_input_file_list() (in module aodncore.pipeline.steps.harvest) create_symlink() (in module aodncore.pipeline.steps.harvest) create_table_from_yaml_file() (aodncore.pipeline.db.DatabaseInteractions method) CSV (aodncore.pipeline.common.FileType attribute) (aodncore.pipeline.FileType attribute) CsvHarvesterRunner (class in aodncore.pipeline.steps.harvest)

D

DatabaseInteractions (class in aodncore.pipeline.db) default_addition_publish_type (aodncore.pipeline.HandlerBase property) (aodncore.pipeline.handlerbase.HandlerBase property) default_deletion_publish_type (aodncore.pipeline.HandlerBase property) (aodncore.pipeline.handlerbase.HandlerBase property) delete() (aodncore.testlib.NullStorageBroker method) (aodncore.testlib.testutil.NullStorageBroker method) DELETE_MANIFEST (aodncore.pipeline.common.FileType attribute) (aodncore.pipeline.FileType attribute) DELETE_ONLY (aodncore.pipeline.common.PipelineFilePublishType attribute) (aodncore.pipeline.PipelineFilePublishType attribute) DELETE_PATTERN (aodncore.pipeline.steps.resolve.RsyncManifestResolveRunner attribute) DELETE_UNHARVEST (aodncore.pipeline.common.PipelineFilePublishType attribute) (aodncore.pipeline.PipelineFilePublishType attribute) DeleteManifestResolveRunner (class in aodncore.pipeline.steps.resolve) deleter() (aodncore.util.classproperty method) dest_path (aodncore.pipeline.files.PipelineFile property) (aodncore.pipeline.PipelineFile property) dest_path() (aodncore.testlib.DummyHandler static method) (aodncore.testlib.dummyhandler.DummyHandler static method) dest_path_attr (aodncore.pipeline.steps.store.StoreRunner property) dest_path_testing() (in module aodncore.testlib) (in module aodncore.testlib.testutil) dict_to_xml() (in module aodncore.pipeline.geonetwork) difference() (aodncore.pipeline.steps.notify.NotifyList method) (aodncore.pipeline.steps.NotifyList method) (aodncore.util.IndexedSet method)

difference_update() (aodncore.util.IndexedSet method) DIR_ADD_PATTERN (aodncore.pipeline.steps.resolve.RsyncManifestResolveRunner attribute) dir_exists() (in module aodncore.util.fileops) DIR_MANIFEST (aodncore.pipeline.common.FileType attribute) (aodncore.pipeline.FileType attribute) DirManifestResolveRunner (class in aodncore.pipeline.steps.resolve) discard() (aodncore.pipeline.steps.notify.NotifyList method) (aodncore.pipeline.steps.NotifyList method) (aodncore.util.IndexedSet method) discover_entry_points() (in module aodncore.util) (in module aodncore.util.misc) discovered_dest_path_functions (aodncore.pipeline.configlib.LazyConfigManager property) discovered_handlers (aodncore.pipeline.configlib.LazyConfigManager property) discovered_module_versions (aodncore.pipeline.configlib.LazyConfigManager property) download() (aodncore.pipeline.files.RemotePipelineFileCollection method) (aodncore.pipeline.RemotePipelineFileCollection method) (aodncore.pipeline.statequery.StateQuery method) (aodncore.testlib.NullStorageBroker method) (aodncore.testlib.testutil.NullStorageBroker method) drop_object() (aodncore.pipeline.db.DatabaseInteractions method) DummyHandler (class in aodncore.testlib) (class in aodncore.testlib.dummyhandler) DuplicatePipelineFileError

E

EMAIL (aodncore.pipeline.common.NotificationRecipientType attribute) (aodncore.pipeline.NotificationRecipientType attribute) EmailNotifyRunner (class in aodncore.pipeline.steps.notify) ensure_pipelinefilecollection() (in module aodncore.pipeline.files) ensure_regex() (in module aodncore.util) (in module aodncore.util.misc) ensure_regex_list() (in module aodncore.util) (in module aodncore.util.misc) ensure_remotepipelinefilecollection() (in module aodncore.pipeline.files) ensure_writeonceordereddict() (in module aodncore.util) (in module aodncore.util.misc) ERROR (aodncore.pipeline.common.HandlerResult attribute) error (aodncore.pipeline.HandlerBase property) (aodncore.pipeline.handlerbase.HandlerBase property) ERROR (aodncore.pipeline.HandlerResult attribute) error_broker (aodncore.pipeline.watch.IncomingFileStateManager property) error_details (aodncore.pipeline.HandlerBase property) (aodncore.pipeline.handlerbase.HandlerBase property) error_mode (aodncore.pipeline.watch.IncomingFileStateManager attribute) error_name (aodncore.pipeline.watch.IncomingFileStateManager property)

error_string (aodncore.pipeline.common.NotificationRecipientType property) (aodncore.pipeline.NotificationRecipientType property) error_uri (aodncore.pipeline.watch.IncomingFileStateManager property) errors (aodncore.pipeline.CheckResult property) (aodncore.pipeline.common.CheckResult property) EVENT_MASK (aodncore.pipeline.watch.WatchServiceManager attribute) exclude_regexes (aodncore.pipeline.HandlerBase property) (aodncore.pipeline.handlerbase.HandlerBase property) execute() (aodncore.util.process.SystemProcess method) (aodncore.util.SystemProcess method) execute_sql_file() (aodncore.pipeline.db.DatabaseInteractions method) execute_talend() (aodncore.pipeline.steps.harvest.TalendHarvesterRunner method) executor_conversion() (in module aodncore.pipeline.steps.harvest) extensions (aodncore.pipeline.common.FileType attribute) (aodncore.pipeline.FileType attribute) extra_params (aodncore.pipeline.steps.harvest.TriggerEvent property) extract_gzip() (in module aodncore.util) (in module aodncore.util.fileops) extract_zip() (in module aodncore.util) (in module aodncore.util.fileops)

F

FILE_ADD_PATTERN (aodncore.pipeline.steps.resolve.RsyncManifestResolveRunner attribute) file_basename (aodncore.pipeline.HandlerBase property) (aodncore.pipeline.handlerbase.HandlerBase property) file_checksum (aodncore.pipeline.files.PipelineFile property) (aodncore.pipeline.files.RemotePipelineFile property) (aodncore.pipeline.HandlerBase property) (aodncore.pipeline.handlerbase.HandlerBase property) (aodncore.pipeline.PipelineFile property) (aodncore.pipeline.RemotePipelineFile property) file_collection (aodncore.pipeline.HandlerBase property) (aodncore.pipeline.handlerbase.HandlerBase property) file_extension (aodncore.pipeline.HandlerBase property) (aodncore.pipeline.handlerbase.HandlerBase property) file_type (aodncore.pipeline.HandlerBase property) (aodncore.pipeline.handlerbase.HandlerBase property) file_update_callback (aodncore.pipeline.files.PipelineFile property) (aodncore.pipeline.PipelineFile property) FileClassifier (class in aodncore.pipeline) (class in aodncore.pipeline.fileclassifier) FileType (class in aodncore.pipeline) (class in aodncore.pipeline.common) filter_by_failed() (aodncore.pipeline.steps.notify.NotifyList method) (aodncore.pipeline.steps.NotifyList method) filter_by_notify_type() (aodncore.pipeline.steps.notify.NotifyList method) (aodncore.pipeline.steps.NotifyList method) filter_by_succeeded() (aodncore.pipeline.steps.notify.NotifyList method) (aodncore.pipeline.steps.NotifyList method)

find_file() (in module aodncore.util) (in module aodncore.util.fileops) findall() (aodncore.util.misc.Pattern method) (aodncore.util.Pattern method) finditer() (aodncore.util.misc.Pattern method) (aodncore.util.Pattern method) flags (aodncore.util.misc.Pattern attribute) (aodncore.util.Pattern attribute) FORMAT_CHECK (aodncore.pipeline.common.PipelineFileCheckType attribute) (aodncore.pipeline.PipelineFileCheckType attribute) format_exception() (in module aodncore.util) (in module aodncore.util.misc) FormatCheckRunner (class in aodncore.pipeline.steps.check) from_collection() (aodncore.pipeline.steps.notify.NotifyList class method) (aodncore.pipeline.steps.NotifyList class method) from_iterable() (aodncore.util.IndexedSet class method) from_pipelinefile() (aodncore.pipeline.files.RemotePipelineFile class method) (aodncore.pipeline.RemotePipelineFile class method) from_pipelinefilecollection() (aodncore.pipeline.files.RemotePipelineFileCollection class method) (aodncore.pipeline.RemotePipelineFileCollection class method) from_remotepipelinefile() (aodncore.pipeline.files.PipelineFile class method) (aodncore.pipeline.PipelineFile class method) from_remotepipelinefilecollection() (aodncore.pipeline.files.PipelineFileCollection class method) (aodncore.pipeline.PipelineFileCollection class method) from_string() (aodncore.pipeline.steps.NotificationRecipient class method) (aodncore.pipeline.steps.notify.NotificationRecipient class method) fullmatch() (aodncore.util.misc.Pattern method) (aodncore.util.Pattern method)

G

generate_id() (in module aodncore.util) (in module aodncore.util.misc) Geonetwork (class in aodncore.pipeline.geonetwork) geonetwork_exception_handler() (in module aodncore.pipeline.geonetwork) GeonetworkConnectionError GeonetworkMetadataHandler (class in aodncore.pipeline.geonetwork) GeonetworkRequestError get_check_runner() (in module aodncore.pipeline.steps) (in module aodncore.pipeline.steps.check) get_child_check_runner() (in module aodncore.pipeline.steps) (in module aodncore.pipeline.steps.check) get_config_file() (aodncore.pipeline.steps.harvest.CsvHarvesterRunner method) get_field_type() (in module aodncore.table) (in module aodncore.table.ff) get_file_checksum() (in module aodncore.util) (in module aodncore.util.fileops) get_harvester_runner() (in module aodncore.pipeline.steps) (in module aodncore.pipeline.steps.harvest) get_namespace_dict() (aodncore.pipeline.geonetwork.GeonetworkMetadataHandler method) get_nonexistent_path() (in module aodncore.testlib) (in module aodncore.testlib.testutil) get_notify_runner() (in module aodncore.pipeline.steps) (in module aodncore.pipeline.steps.notify) get_ogc_expression_for_file_url() (in module aodncore.util.wfs) get_path_function() (in module aodncore.pipeline.destpath) get_pattern_subgroups_from_string() (in module aodncore.util) (in module aodncore.util.misc) get_pipeline_logger() (in module aodncore.pipeline.log) get_process_sequence() (aodncore.pipeline.steps.harvest.CsvHarvesterRunner method) get_record() (aodncore.pipeline.geonetwork.Geonetwork method) get_regex_subgroups_from_string() (in module aodncore.util.misc) get_resolve_runner() (in module aodncore.pipeline.steps) (in module aodncore.pipeline.steps.resolve)

get_spatial_extent() (aodncore.pipeline.db.DatabaseInteractions method) get_storage_broker() (in module aodncore.pipeline.storage) get_store_runner() (in module aodncore.pipeline.steps) (in module aodncore.pipeline.steps.store) get_tableschema_descriptor() (in module aodncore.table) (in module aodncore.table.ff) get_task_name() (in module aodncore.pipeline.watch) get_temporal_extent() (aodncore.pipeline.db.DatabaseInteractions method) get_test_config() (in module aodncore.testlib) (in module aodncore.testlib.testutil) get_type_from_extension() (aodncore.pipeline.common.FileType class method) (aodncore.pipeline.FileType class method) get_type_from_name() (aodncore.pipeline.common.FileType class method) (aodncore.pipeline.common.PipelineFilePublishType class method) (aodncore.pipeline.FileType class method) (aodncore.pipeline.PipelineFilePublishType class method) get_type_from_protocol() (aodncore.pipeline.common.NotificationRecipientType class method) (aodncore.pipeline.NotificationRecipientType class method) get_url_property_name() (aodncore.util.wfs.WfsBroker method) (aodncore.util.WfsBroker method) get_vertical_extent() (aodncore.pipeline.db.DatabaseInteractions method) get_watchservice_logging_config() (in module aodncore.pipeline.log) get_worker_logging_config() (aodncore.pipeline.configlib.LazyConfigManager method) getfeature_dict() (aodncore.util.wfs.WfsBroker method) (aodncore.util.WfsBroker method) getter() (aodncore.util.classproperty method) groupindex (aodncore.util.misc.Pattern attribute) (aodncore.util.Pattern attribute) groups (aodncore.util.misc.Pattern attribute) (aodncore.util.Pattern attribute) GZIP (aodncore.pipeline.common.FileType attribute) (aodncore.pipeline.FileType attribute) GzipFileResolveRunner (class in aodncore.pipeline.steps.resolve)

H

handle_signal() (aodncore.pipeline.watch.WatchServiceManager method) HandlerAlreadyRunError HandlerBase (class in aodncore.pipeline) (class in aodncore.pipeline.handlerbase) HandlerResult (class in aodncore.pipeline) (class in aodncore.pipeline.common) HandlerTestCase (class in aodncore.testlib) (class in aodncore.testlib.handlertest) HARVEST_ARCHIVE (aodncore.pipeline.common.PipelineFilePublishType attribute) (aodncore.pipeline.PipelineFilePublishType attribute)

HARVEST_ARCHIVE_UPLOAD (aodncore.pipeline.common.PipelineFilePublishType attribute) (aodncore.pipeline.PipelineFilePublishType attribute) HARVEST_ONLY (aodncore.pipeline.common.PipelineFilePublishType attribute) (aodncore.pipeline.PipelineFilePublishType attribute) HARVEST_UPLOAD (aodncore.pipeline.common.PipelineFilePublishType attribute) (aodncore.pipeline.PipelineFilePublishType attribute) HarvesterMap (class in aodncore.pipeline.steps.harvest) HEADER_LINE (aodncore.pipeline.steps.resolve.RsyncManifestResolveRunner attribute)

I

include_regexes (aodncore.pipeline.HandlerBase property) (aodncore.pipeline.handlerbase.HandlerBase property) incoming_dir (aodncore.pipeline.watch.IncomingFileStateManager property) IncomingFileEventHandler (class in aodncore.pipeline.watch) IncomingFileStateManager (class in aodncore.pipeline.watch) index() (aodncore.util.IndexedSet method) IndexedSet (class in aodncore.util) input_file_archive_path (aodncore.pipeline.HandlerBase property) (aodncore.pipeline.handlerbase.HandlerBase property) input_file_object (aodncore.pipeline.HandlerBase property) (aodncore.pipeline.handlerbase.HandlerBase property) instance_working_directory (aodncore.pipeline.HandlerBase property) (aodncore.pipeline.handlerbase.HandlerBase property) intersection() (aodncore.util.IndexedSet method) intersection_update() (aodncore.util.IndexedSet method) INVALID (aodncore.pipeline.common.NotificationRecipientType attribute) (aodncore.pipeline.NotificationRecipientType attribute) InvalidCheckSuiteError InvalidCheckTypeError InvalidConfigError InvalidFileContentError InvalidFileFormatError InvalidFileNameError InvalidHandlerError InvalidHarvesterError InvalidHarvestMapError InvalidInputFileError InvalidPathFunctionError InvalidRecipientError InvalidSchemaError InvalidSQLConnectionError InvalidSQLTransactionError InvalidStoreUrlError is_addition_type (aodncore.pipeline.common.PipelineFilePublishType property) (aodncore.pipeline.PipelineFilePublishType property) is_archive_type (aodncore.pipeline.common.PipelineFilePublishType property) (aodncore.pipeline.PipelineFilePublishType property) is_archived (aodncore.pipeline.files.PipelineFile property) (aodncore.pipeline.PipelineFile property) is_checked (aodncore.pipeline.files.PipelineFile property) (aodncore.pipeline.PipelineFile property) is_collection_superset() (aodncore.pipeline.steps.harvest.HarvesterMap method) is_deleted (aodncore.pipeline.files.PipelineFile property) (aodncore.pipeline.PipelineFile property) is_deletion (aodncore.pipeline.files.PipelineFile property) (aodncore.pipeline.PipelineFile property) is_deletion_type (aodncore.pipeline.common.PipelineFilePublishType property) (aodncore.pipeline.PipelineFilePublishType property) is_dir_writable() (in module aodncore.util) (in module aodncore.util.fileops) is_file_writable() (in module aodncore.util.fileops) is_function() (in module aodncore.util) (in module aodncore.util.misc) is_gzip_file() (in module aodncore.util) (in module aodncore.util.fileops)

is_harvest_type (aodncore.pipeline.common.PipelineFilePublishType property) (aodncore.pipeline.PipelineFilePublishType property) is_harvest_undone (aodncore.pipeline.files.PipelineFile property) (aodncore.pipeline.PipelineFile property) is_harvested (aodncore.pipeline.files.PipelineFile property) (aodncore.pipeline.PipelineFile property) is_image_type (aodncore.pipeline.common.FileType property) (aodncore.pipeline.FileType property) is_jpeg_file() (in module aodncore.util) (in module aodncore.util.fileops) is_json_file() (in module aodncore.util) (in module aodncore.util.fileops) is_netcdf_file() (in module aodncore.util) (in module aodncore.util.fileops) is_nonempty_file() (in module aodncore.util) (in module aodncore.util.fileops) is_nonstring_iterable() (in module aodncore.util) (in module aodncore.util.misc) is_overwrite (aodncore.pipeline.files.PipelineFile property) (aodncore.pipeline.PipelineFile property) is_pdf_file() (in module aodncore.util) (in module aodncore.util.fileops) is_png_file() (in module aodncore.util) (in module aodncore.util.fileops) is_store_type (aodncore.pipeline.common.PipelineFilePublishType property) (aodncore.pipeline.PipelineFilePublishType property) is_stored (aodncore.pipeline.files.PipelineFile property) (aodncore.pipeline.PipelineFile property) is_stored_attr (aodncore.pipeline.steps.store.StoreRunner property) is_tiff_file() (in module aodncore.util) (in module aodncore.util.fileops) is_type() (aodncore.pipeline.common.FileType method) (aodncore.pipeline.FileType method) is_upload_undone (aodncore.pipeline.files.PipelineFile property) (aodncore.pipeline.PipelineFile property) is_uploaded (aodncore.pipeline.files.PipelineFile property) (aodncore.pipeline.PipelineFile property) is_valid_email_address() (in module aodncore.util) (in module aodncore.util.misc) is_zip_file() (in module aodncore.util) (in module aodncore.util.fileops) isdisjoint() (aodncore.util.IndexedSet method) issubset() (aodncore.pipeline.steps.notify.NotifyList method) (aodncore.pipeline.steps.NotifyList method) (aodncore.util.IndexedSet method) issuperset() (aodncore.pipeline.steps.notify.NotifyList method) (aodncore.pipeline.steps.NotifyList method) (aodncore.util.IndexedSet method) iter_difference() (aodncore.util.IndexedSet method) iter_intersection() (aodncore.util.IndexedSet method) iter_public_attributes() (in module aodncore.util) (in module aodncore.util.misc) iter_slice() (aodncore.util.IndexedSet method)

J

JPEG (aodncore.pipeline.common.FileType attribute) (aodncore.pipeline.FileType attribute)

JSON_MANIFEST (aodncore.pipeline.common.FileType attribute) (aodncore.pipeline.FileType attribute) JsonManifestResolveRunner (class in aodncore.pipeline.steps.resolve)

K

keys() (aodncore.pipeline.files.RemotePipelineFileCollection method) (aodncore.pipeline.RemotePipelineFileCollection method)

L

last_modified (aodncore.pipeline.files.RemotePipelineFile property) (aodncore.pipeline.RemotePipelineFile property) late_deletion (aodncore.pipeline.files.PipelineFile property) (aodncore.pipeline.PipelineFile property) LazyConfigManager (class in aodncore.pipeline.configlib) lazyproperty (class in aodncore.util) list_not_empty() (in module aodncore.util) (in module aodncore.util.misc) list_regular_files() (in module aodncore.util) (in module aodncore.util.fileops) load_data_from_csv() (aodncore.pipeline.db.DatabaseInteractions method) load_json_file() (in module aodncore.pipeline.configlib) load_pipeline_config() (in module aodncore.pipeline.configlib)

load_runtime_patched_pipeline_config_file() (in module aodncore.testlib.testutil) load_trigger_config() (in module aodncore.pipeline.configlib) load_watch_config() (in module aodncore.pipeline.configlib) local_path (aodncore.pipeline.files.RemotePipelineFile property) (aodncore.pipeline.RemotePipelineFile property) LocalFileStorageBroker (class in aodncore.pipeline.storage) log (aodncore.pipeline.CheckResult property) (aodncore.pipeline.common.CheckResult property) LogFailuresNotifyRunner (class in aodncore.pipeline.steps.notify) logger (aodncore.pipeline.HandlerBase property) (aodncore.pipeline.handlerbase.HandlerBase property) LoggingContext (class in aodncore.util) (class in aodncore.util.misc)

M

make_test_file() (in module aodncore.testlib) (in module aodncore.testlib.testutil) make_zip() (in module aodncore.testlib) (in module aodncore.testlib.testutil) map (aodncore.pipeline.steps.harvest.HarvesterMap property) MAP_MANIFEST (aodncore.pipeline.common.FileType attribute) (aodncore.pipeline.FileType attribute) MapManifestResolveRunner (class in aodncore.pipeline.steps.resolve) match() (aodncore.util.misc.Pattern method) (aodncore.util.Pattern method) match_harvester_to_files() (aodncore.pipeline.steps.harvest.TalendHarvesterRunner method) matched_files (aodncore.pipeline.steps.harvest.TriggerEvent property) matches_regexes() (in module aodncore.util) (in module aodncore.util.misc) member_class (aodncore.pipeline.files.PipelineFileCollection attribute) (aodncore.pipeline.files.RemotePipelineFileCollection attribute) (aodncore.pipeline.PipelineFileCollection attribute) (aodncore.pipeline.RemotePipelineFileCollection attribute) member_from_string_method (aodncore.pipeline.files.PipelineFileCollection property) (aodncore.pipeline.files.RemotePipelineFileCollection property) (aodncore.pipeline.PipelineFileCollection property) (aodncore.pipeline.RemotePipelineFileCollection property) member_validator() (aodncore.pipeline.files.PipelineFileCollection method) (aodncore.pipeline.files.RemotePipelineFileCollection method) (aodncore.pipeline.PipelineFileCollection method) (aodncore.pipeline.RemotePipelineFileCollection method) merge() (aodncore.pipeline.steps.harvest.HarvesterMap method) merge_dicts() (in module aodncore.util) (in module aodncore.util.misc) mime_type (aodncore.pipeline.common.FileType attribute) (aodncore.pipeline.files.PipelineFile property) (aodncore.pipeline.FileType attribute) (aodncore.pipeline.PipelineFile property) MissingConfigFileError MissingConfigParameterError MissingFileError mkdir_p() (in module aodncore.util) (in module aodncore.util.fileops) module aodncore aodncore.common aodncore.common.exceptions aodncore.pipeline aodncore.pipeline.common aodncore.pipeline.config aodncore.pipeline.configlib aodncore.pipeline.db aodncore.pipeline.destpath aodncore.pipeline.exceptions aodncore.pipeline.fileclassifier aodncore.pipeline.files aodncore.pipeline.geonetwork aodncore.pipeline.handlerbase aodncore.pipeline.log aodncore.pipeline.schema aodncore.pipeline.statequery aodncore.pipeline.steps aodncore.pipeline.steps.basestep aodncore.pipeline.steps.check aodncore.pipeline.steps.harvest aodncore.pipeline.steps.notify aodncore.pipeline.steps.resolve aodncore.pipeline.steps.store aodncore.pipeline.storage aodncore.pipeline.templates aodncore.pipeline.watch aodncore.table aodncore.table.ff aodncore.testlib aodncore.testlib.basetest aodncore.testlib.dummyhandler aodncore.testlib.handlertest aodncore.testlib.testutil aodncore.util aodncore.util.fileops aodncore.util.misc aodncore.util.process aodncore.util.wfs

N

NC_COMPLIANCE_CHECK (aodncore.pipeline.common.PipelineFileCheckType attribute) (aodncore.pipeline.PipelineFileCheckType attribute) NETCDF (aodncore.pipeline.common.FileType attribute) (aodncore.pipeline.FileType attribute) NO_ACTION (aodncore.pipeline.common.PipelineFileCheckType attribute) (aodncore.pipeline.common.PipelineFilePublishType attribute) (aodncore.pipeline.PipelineFileCheckType attribute) (aodncore.pipeline.PipelineFilePublishType attribute) NONEMPTY_CHECK (aodncore.pipeline.common.PipelineFileCheckType attribute) (aodncore.pipeline.PipelineFileCheckType attribute) NonEmptyCheckRunner (class in aodncore.pipeline.steps.check) notification_attempted (aodncore.pipeline.steps.NotificationRecipient property) (aodncore.pipeline.steps.notify.NotificationRecipient property) notification_results (aodncore.pipeline.HandlerBase property) (aodncore.pipeline.handlerbase.HandlerBase property)

notification_succeeded (aodncore.pipeline.steps.NotificationRecipient property) (aodncore.pipeline.steps.notify.NotificationRecipient property) NotificationFailedError NotificationRecipient (class in aodncore.pipeline.steps) (class in aodncore.pipeline.steps.notify) NotificationRecipientType (class in aodncore.pipeline) (class in aodncore.pipeline.common) notify_type (aodncore.pipeline.steps.NotificationRecipient property) (aodncore.pipeline.steps.notify.NotificationRecipient property) NotifyList (class in aodncore.pipeline.steps) (class in aodncore.pipeline.steps.notify) NotifyRunnerAdapter (class in aodncore.pipeline.steps.notify) NullStorageBroker (class in aodncore.testlib) (class in aodncore.testlib.testutil)

O

ogc_filter_to_string() (in module aodncore.util.wfs) ordered_states (aodncore.pipeline.HandlerBase attribute) (aodncore.pipeline.handlerbase.HandlerBase attribute) ordered_transitions (aodncore.pipeline.HandlerBase attribute) (aodncore.pipeline.handlerbase.HandlerBase attribute)

other_states (aodncore.pipeline.HandlerBase attribute) (aodncore.pipeline.handlerbase.HandlerBase attribute) other_transitions (aodncore.pipeline.HandlerBase attribute) (aodncore.pipeline.handlerbase.HandlerBase attribute)

P

pattern (aodncore.util.misc.Pattern attribute) (aodncore.util.Pattern attribute) Pattern (class in aodncore.util) (class in aodncore.util.misc) PDF (aodncore.pipeline.common.FileType attribute) (aodncore.pipeline.FileType attribute) pending_addition_attr (aodncore.pipeline.steps.store.StoreRunner property) pending_archive (aodncore.pipeline.files.PipelineFile property) (aodncore.pipeline.PipelineFile property) pending_harvest (aodncore.pipeline.files.PipelineFile property) (aodncore.pipeline.PipelineFile property) pending_harvest_addition (aodncore.pipeline.files.PipelineFile property) (aodncore.pipeline.PipelineFile property) pending_harvest_deletion (aodncore.pipeline.files.PipelineFile property) (aodncore.pipeline.PipelineFile property) pending_harvest_early_deletion (aodncore.pipeline.files.PipelineFile property) (aodncore.pipeline.PipelineFile property) pending_harvest_late_deletion (aodncore.pipeline.files.PipelineFile property) (aodncore.pipeline.PipelineFile property) pending_harvest_undo (aodncore.pipeline.files.PipelineFile property) (aodncore.pipeline.PipelineFile property) pending_store (aodncore.pipeline.files.PipelineFile property) (aodncore.pipeline.PipelineFile property) pending_store_addition (aodncore.pipeline.files.PipelineFile property) (aodncore.pipeline.PipelineFile property) pending_store_deletion (aodncore.pipeline.files.PipelineFile property) (aodncore.pipeline.PipelineFile property) pending_store_undo (aodncore.pipeline.files.PipelineFile property) (aodncore.pipeline.PipelineFile property) pending_undo (aodncore.pipeline.files.PipelineFile property) (aodncore.pipeline.PipelineFile property) pipeline_config (aodncore.pipeline.configlib.LazyConfigManager property) PipelineFile (class in aodncore.pipeline) (class in aodncore.pipeline.files) PipelineFileCheckType (class in aodncore.pipeline) (class in aodncore.pipeline.common)

PipelineFileCollection (class in aodncore.pipeline) (class in aodncore.pipeline.files) PipelineFilePublishType (class in aodncore.pipeline) (class in aodncore.pipeline.common) PipelineProcessingError PipelineSystemError PNG (aodncore.pipeline.common.FileType attribute) (aodncore.pipeline.FileType attribute) pop() (aodncore.util.IndexedSet method) (aodncore.util.misc.WriteOnceOrderedDict method) (aodncore.util.WriteOnceOrderedDict method) popitem() (aodncore.util.misc.WriteOnceOrderedDict method) (aodncore.util.WriteOnceOrderedDict method) postprocess() (aodncore.pipeline.HandlerBase method) (aodncore.pipeline.handlerbase.HandlerBase method) (aodncore.testlib.DummyHandler method) (aodncore.testlib.dummyhandler.DummyHandler method) preprocess() (aodncore.pipeline.HandlerBase method) (aodncore.pipeline.handlerbase.HandlerBase method) (aodncore.testlib.DummyHandler method) (aodncore.testlib.dummyhandler.DummyHandler method) process() (aodncore.pipeline.HandlerBase method) (aodncore.pipeline.handlerbase.HandlerBase method) (aodncore.testlib.DummyHandler method) (aodncore.testlib.dummyhandler.DummyHandler method) process_default() (aodncore.pipeline.watch.IncomingFileEventHandler method) processing_dir (aodncore.pipeline.watch.IncomingFileStateManager property) processing_mode (aodncore.pipeline.watch.IncomingFileStateManager attribute) processing_path (aodncore.pipeline.watch.IncomingFileStateManager property) products_dir (aodncore.pipeline.HandlerBase property) (aodncore.pipeline.handlerbase.HandlerBase property) protocol (aodncore.pipeline.common.NotificationRecipientType property) (aodncore.pipeline.NotificationRecipientType property) publish_type (aodncore.pipeline.files.PipelineFile property) (aodncore.pipeline.PipelineFile property) published (aodncore.pipeline.files.PipelineFile property) (aodncore.pipeline.PipelineFile property)

Q

query() (aodncore.testlib.NullStorageBroker method) (aodncore.testlib.testutil.NullStorageBroker method) query_file_exists() (aodncore.util.wfs.WfsBroker method) (aodncore.util.WfsBroker method) query_files() (aodncore.util.wfs.WfsBroker method) (aodncore.util.WfsBroker method) query_storage() (aodncore.pipeline.statequery.StateQuery method)

query_urls_for_layer() (aodncore.util.wfs.WfsBroker method) (aodncore.util.WfsBroker method) query_wfs_file_exists() (aodncore.pipeline.statequery.StateQuery method) query_wfs_files() (aodncore.pipeline.statequery.StateQuery method) query_wfs_getfeature_dict() (aodncore.pipeline.statequery.StateQuery method) query_wfs_urls_for_layer() (aodncore.pipeline.statequery.StateQuery method) queue_task() (aodncore.pipeline.watch.IncomingFileEventHandler method)

R

raw_string (aodncore.pipeline.steps.NotificationRecipient property) (aodncore.pipeline.steps.notify.NotificationRecipient property) RECORD_PATTERN (aodncore.pipeline.steps.resolve.RsyncManifestResolveRunner attribute) refresh_materialized_view() (aodncore.pipeline.db.DatabaseInteractions method) relative_path (aodncore.pipeline.watch.IncomingFileStateManager property) RemotePipelineFile (class in aodncore.pipeline) (class in aodncore.pipeline.files) RemotePipelineFileCollection (class in aodncore.pipeline) (class in aodncore.pipeline.files) remove() (aodncore.util.IndexedSet method) remove_local() (aodncore.pipeline.files.RemotePipelineFile method) (aodncore.pipeline.RemotePipelineFile method) render() (aodncore.util.misc.TemplateRenderer method) (aodncore.util.TemplateRenderer method) result (aodncore.pipeline.HandlerBase property) (aodncore.pipeline.handlerbase.HandlerBase property) result_serializer (aodncore.pipeline.watch.CeleryConfig attribute) result_to_remote_pipelinefile_collection() (aodncore.pipeline.storage.S3StorageBroker static method) retry_decorator() (in module aodncore.util) retry_kwargs (aodncore.pipeline.storage.S3StorageBroker attribute) reverse() (aodncore.util.IndexedSet method) rm_f() (in module aodncore.util) (in module aodncore.util.fileops) rm_r() (in module aodncore.util) (in module aodncore.util.fileops) rm_rf() (in module aodncore.util) (in module aodncore.util.fileops) RSYNC_MANIFEST (aodncore.pipeline.common.FileType attribute) (aodncore.pipeline.FileType attribute)

RsyncManifestResolveRunner (class in aodncore.pipeline.steps.resolve) run() (aodncore.pipeline.geonetwork.GeonetworkMetadataHandler method) (aodncore.pipeline.HandlerBase method) (aodncore.pipeline.handlerbase.HandlerBase method) (aodncore.pipeline.steps.check.CheckRunnerAdapter method) (aodncore.pipeline.steps.check.ComplianceCheckerCheckRunner method) (aodncore.pipeline.steps.check.FormatCheckRunner method) (aodncore.pipeline.steps.check.NonEmptyCheckRunner method) (aodncore.pipeline.steps.check.TableSchemaCheckRunner method) (aodncore.pipeline.steps.harvest.CsvHarvesterRunner method) (aodncore.pipeline.steps.harvest.TalendHarvesterRunner method) (aodncore.pipeline.steps.notify.EmailNotifyRunner method) (aodncore.pipeline.steps.notify.LogFailuresNotifyRunner method) (aodncore.pipeline.steps.notify.NotifyRunnerAdapter method) (aodncore.pipeline.steps.notify.SnsNotifyRunner method) (aodncore.pipeline.steps.resolve.DirManifestResolveRunner method) (aodncore.pipeline.steps.resolve.GzipFileResolveRunner method) (aodncore.pipeline.steps.resolve.JsonManifestResolveRunner method) (aodncore.pipeline.steps.resolve.RsyncManifestResolveRunner method) (aodncore.pipeline.steps.resolve.SimpleManifestResolveRunner method) (aodncore.pipeline.steps.resolve.SingleFileResolveRunner method) (aodncore.pipeline.steps.resolve.ZipFileResolveRunner method) (aodncore.pipeline.steps.store.StoreRunner method) run_additions() (aodncore.pipeline.steps.harvest.TalendHarvesterRunner method) run_deletions() (aodncore.pipeline.steps.harvest.TalendHarvesterRunner method) run_handler() (aodncore.testlib.handlertest.HandlerTestCase method) (aodncore.testlib.HandlerTestCase method) run_handler_with_exception() (aodncore.testlib.handlertest.HandlerTestCase method) (aodncore.testlib.HandlerTestCase method) run_undo_deletions() (aodncore.pipeline.steps.harvest.TalendHarvesterRunner method)

S

S3StorageBroker (class in aodncore.pipeline.storage) safe_copy_file() (in module aodncore.util) (in module aodncore.util.fileops) safe_move_file() (in module aodncore.util) (in module aodncore.util.fileops) scanner() (aodncore.util.misc.Pattern method) (aodncore.util.Pattern method) schema (aodncore.pipeline.steps.resolve.DeleteManifestResolveRunner property) (aodncore.pipeline.steps.resolve.MapManifestResolveRunner property) search() (aodncore.util.misc.Pattern method) (aodncore.util.Pattern method) set_archive_paths() (aodncore.pipeline.files.PipelineFileCollection method) (aodncore.pipeline.PipelineFileCollection method) set_bool_attribute() (aodncore.pipeline.files.PipelineFileCollection method) (aodncore.pipeline.PipelineFileCollection method) set_check_types() (aodncore.pipeline.files.PipelineFileCollection method) (aodncore.pipeline.PipelineFileCollection method) set_default_check_types() (aodncore.pipeline.files.PipelineFileCollection method) (aodncore.pipeline.PipelineFileCollection method) set_dest_paths() (aodncore.pipeline.files.PipelineFileCollection method) (aodncore.pipeline.PipelineFileCollection method) set_error() (aodncore.pipeline.steps.notify.NotifyList method) (aodncore.pipeline.steps.NotifyList method) set_file_update_callback() (aodncore.pipeline.files.PipelineFileCollection method) (aodncore.pipeline.PipelineFileCollection method) set_is_overwrite() (aodncore.pipeline.steps.store.StoreRunner method) set_notification_attempted() (aodncore.pipeline.steps.notify.NotifyList method) (aodncore.pipeline.steps.NotifyList method) set_pipelinefile_bool_attribute() (aodncore.pipeline.steps.harvest.HarvesterMap method) set_publish_types() (aodncore.pipeline.files.PipelineFileCollection method) (aodncore.pipeline.PipelineFileCollection method) set_publish_types_from_regexes() (aodncore.pipeline.files.PipelineFileCollection method) (aodncore.pipeline.PipelineFileCollection method) set_string_attribute() (aodncore.pipeline.files.PipelineFileCollection method) (aodncore.pipeline.PipelineFileCollection method) setdefault() (aodncore.util.misc.WriteOnceOrderedDict method) (aodncore.util.WriteOnceOrderedDict method) setter() (aodncore.util.classproperty method) setUp() (aodncore.testlib.basetest.BaseTestCase method) (aodncore.testlib.BaseTestCase method) (aodncore.testlib.handlertest.HandlerTestCase method) (aodncore.testlib.HandlerTestCase method) setUpClass() (aodncore.testlib.handlertest.HandlerTestCase class method) (aodncore.testlib.HandlerTestCase class method) sftp_makedirs() (in module aodncore.pipeline.storage) sftp_mkdir_p() (in module aodncore.pipeline.storage) sftp_path_exists() (in module aodncore.pipeline.storage) SftpStorageBroker (class in aodncore.pipeline.storage)

should_archive (aodncore.pipeline.files.PipelineFile property) (aodncore.pipeline.PipelineFile property) should_harvest (aodncore.pipeline.files.PipelineFile property) (aodncore.pipeline.PipelineFile property) should_notify (aodncore.pipeline.HandlerBase property) (aodncore.pipeline.handlerbase.HandlerBase property) should_store (aodncore.pipeline.files.PipelineFile property) (aodncore.pipeline.PipelineFile property) should_undo (aodncore.pipeline.files.PipelineFile property) (aodncore.pipeline.PipelineFile property) SIMPLE_MANIFEST (aodncore.pipeline.common.FileType attribute) (aodncore.pipeline.FileType attribute) SimpleManifestResolveRunner (class in aodncore.pipeline.steps.resolve) SingleFileResolveRunner (class in aodncore.pipeline.steps.resolve) size (aodncore.pipeline.files.RemotePipelineFile property) (aodncore.pipeline.RemotePipelineFile property) slice_sequence() (in module aodncore.util) (in module aodncore.util.misc) SNS (aodncore.pipeline.common.NotificationRecipientType attribute) (aodncore.pipeline.NotificationRecipientType attribute) SnsNotifyRunner (class in aodncore.pipeline.steps.notify) sort() (aodncore.util.IndexedSet method) split() (aodncore.util.misc.Pattern method) (aodncore.util.Pattern method) src_path (aodncore.pipeline.files.PipelineFile property) (aodncore.pipeline.PipelineFile property) start_time (aodncore.pipeline.HandlerBase property) (aodncore.pipeline.handlerbase.HandlerBase property) state_query (aodncore.pipeline.HandlerBase property) (aodncore.pipeline.handlerbase.HandlerBase property) StateQuery (class in aodncore.pipeline.statequery) states (aodncore.pipeline.watch.IncomingFileStateManager attribute) stop() (aodncore.pipeline.watch.WatchServiceManager method) StorageBrokerError StoreRunner (class in aodncore.pipeline.steps.store) str_to_list() (in module aodncore.util) (in module aodncore.util.misc) sub() (aodncore.util.misc.Pattern method) (aodncore.util.Pattern method) subn() (aodncore.util.misc.Pattern method) (aodncore.util.Pattern method) SUCCESS (aodncore.pipeline.common.HandlerResult attribute) (aodncore.pipeline.HandlerResult attribute) symmetric_difference() (aodncore.util.IndexedSet method) symmetric_difference_update() (aodncore.util.IndexedSet method) SystemCommandFailedError, [1] SystemProcess (class in aodncore.util) (class in aodncore.util.process)

T

TABLE_SCHEMA_CHECK (aodncore.pipeline.common.PipelineFileCheckType attribute) (aodncore.pipeline.PipelineFileCheckType attribute) TableSchemaCheckRunner (class in aodncore.pipeline.steps.check) TalendHarvesterRunner (class in aodncore.pipeline.steps.harvest) task_routes (aodncore.pipeline.watch.CeleryConfig attribute) task_serializer (aodncore.pipeline.watch.CeleryConfig attribute) tearDown() (aodncore.testlib.basetest.BaseTestCase method) (aodncore.testlib.BaseTestCase method) temp_dir (aodncore.pipeline.HandlerBase property) (aodncore.pipeline.handlerbase.HandlerBase property) (aodncore.testlib.basetest.BaseTestCase property) (aodncore.testlib.BaseTestCase property) temp_nc_file (aodncore.testlib.basetest.BaseTestCase property) (aodncore.testlib.BaseTestCase property)

TemplateRenderer (class in aodncore.util) (class in aodncore.util.misc) TemporaryDirectory (class in aodncore.util) (class in aodncore.util.fileops) test_base() (aodncore.testlib.handlertest.HandlerTestCase method) (aodncore.testlib.HandlerTestCase method) TIFF (aodncore.pipeline.common.FileType attribute) (aodncore.pipeline.FileType attribute) transitions (aodncore.pipeline.watch.IncomingFileStateManager attribute) trigger_config (aodncore.pipeline.configlib.LazyConfigManager property) TriggerEvent (class in aodncore.pipeline.steps.harvest) truncate_table() (aodncore.pipeline.db.DatabaseInteractions method)

U

undo_processed_files() (aodncore.pipeline.steps.harvest.TalendHarvesterRunner method) UnexpectedCsvFilesError UNHARVEST_ONLY (aodncore.pipeline.common.PipelineFilePublishType attribute) (aodncore.pipeline.PipelineFilePublishType attribute) union() (aodncore.pipeline.steps.notify.NotifyList method) (aodncore.pipeline.steps.NotifyList method) (aodncore.util.IndexedSet method) unique_attributes (aodncore.pipeline.files.PipelineFileCollection attribute) (aodncore.pipeline.files.RemotePipelineFileCollection attribute) (aodncore.pipeline.PipelineFileCollection attribute) (aodncore.pipeline.RemotePipelineFileCollection attribute) UNKNOWN (aodncore.pipeline.common.FileType attribute) (aodncore.pipeline.common.HandlerResult attribute) (aodncore.pipeline.FileType attribute) (aodncore.pipeline.HandlerResult attribute) UnmappedFilesError UnmatchedFilesError

UNSET (aodncore.pipeline.common.PipelineFileCheckType attribute) (aodncore.pipeline.common.PipelineFilePublishType attribute) (aodncore.pipeline.PipelineFileCheckType attribute) (aodncore.pipeline.PipelineFilePublishType attribute) update() (aodncore.pipeline.steps.notify.NotifyList method) (aodncore.pipeline.steps.NotifyList method) (aodncore.util.IndexedSet method) (aodncore.util.misc.WriteOnceOrderedDict method) (aodncore.util.WriteOnceOrderedDict method) update_from_error_dict() (aodncore.pipeline.steps.notify.NotifyList method) (aodncore.pipeline.steps.NotifyList method) update_record() (aodncore.pipeline.geonetwork.Geonetwork method) upload() (aodncore.testlib.NullStorageBroker method) (aodncore.testlib.testutil.NullStorageBroker method) UPLOAD_ONLY (aodncore.pipeline.common.PipelineFilePublishType attribute) (aodncore.pipeline.PipelineFilePublishType attribute) url_propertyname_candidates (aodncore.util.wfs.WfsBroker attribute) (aodncore.util.WfsBroker attribute)

V

validate() (aodncore.pipeline.steps.check.TableSchemaCheckRunner method) validate_addition_publishtype() (in module aodncore.pipeline.common) validate_bool() (in module aodncore.util) (in module aodncore.util.misc) validate_callable() (in module aodncore.util) (in module aodncore.util.misc) validate_check_params() (in module aodncore.pipeline.schema) validate_checkresult() (in module aodncore.pipeline.common) validate_checktype() (in module aodncore.pipeline.common) validate_command() (aodncore.util.process.SystemProcess method) (aodncore.util.SystemProcess method) validate_custom_params() (in module aodncore.pipeline.schema) validate_deletion_publishtype() (in module aodncore.pipeline.common) validate_dict() (in module aodncore.util) (in module aodncore.util.misc) validate_dir_writable() (in module aodncore.util) (in module aodncore.util.fileops) validate_file_writable() (in module aodncore.util) (in module aodncore.util.fileops) validate_harvest_params() (in module aodncore.pipeline.schema) validate_harvester_mapping() (in module aodncore.pipeline.steps.harvest) validate_harvestermap() (in module aodncore.pipeline.steps.harvest) validate_int() (in module aodncore.util) (in module aodncore.util.misc) validate_json_manifest() (in module aodncore.pipeline.schema) validate_lazyconfigmanager() (in module aodncore.pipeline.configlib) validate_logging_config() (in module aodncore.pipeline.schema) validate_mandatory_elements() (in module aodncore.util) (in module aodncore.util.misc) validate_mapping() (in module aodncore.util) (in module aodncore.util.misc) validate_membership() (in module aodncore.util) (in module aodncore.util.misc)

validate_nonstring_iterable() (in module aodncore.util) (in module aodncore.util.misc) validate_notify_params() (in module aodncore.pipeline.schema) validate_pipeline_config() (in module aodncore.pipeline.schema) validate_pipelinefile_or_pipelinefilecollection() (in module aodncore.pipeline.files) validate_pipelinefile_or_string() (in module aodncore.pipeline) (in module aodncore.pipeline.files) validate_pipelinefilecollection() (in module aodncore.pipeline) (in module aodncore.pipeline.files) validate_publishtype() (in module aodncore.pipeline.common) validate_recipienttype() (in module aodncore.pipeline.common) validate_regex() (in module aodncore.util) (in module aodncore.util.misc) validate_regexes() (in module aodncore.util) (in module aodncore.util.misc) validate_relative_path() (in module aodncore.util) (in module aodncore.util.misc) validate_relative_path_attr() (in module aodncore.util) (in module aodncore.util.misc) validate_resolve_params() (in module aodncore.pipeline.schema) validate_settable_checktype() (in module aodncore.pipeline.common) validate_storage_broker() (in module aodncore.pipeline.storage) validate_string() (in module aodncore.util) (in module aodncore.util.misc) validate_triggerevent() (in module aodncore.pipeline.steps.harvest) validate_type() (in module aodncore.util) (in module aodncore.util.misc) validator (aodncore.pipeline.common.FileType attribute) (aodncore.pipeline.FileType attribute) versions (aodncore.pipeline.HandlerBase property) (aodncore.pipeline.handlerbase.HandlerBase property)

W

watch_config (aodncore.pipeline.configlib.LazyConfigManager property) watch_directory_map (aodncore.pipeline.configlib.LazyConfigManager property) watches (aodncore.pipeline.watch.WatchServiceManager property) watchservice_logging_config (aodncore.pipeline.configlib.LazyConfigManager property) WatchServiceContext (class in aodncore.pipeline.watch) WatchServiceManager (class in aodncore.pipeline.watch) wfs (aodncore.pipeline.statequery.StateQuery property) (aodncore.util.wfs.WfsBroker property) (aodncore.util.WfsBroker property)

WfsBroker (class in aodncore.util) (class in aodncore.util.wfs) worker_max_tasks_per_child (aodncore.pipeline.watch.CeleryConfig attribute) WorkerLoggingConfigBuilder (class in aodncore.pipeline.log) WriteOnceOrderedDict (class in aodncore.util) (class in aodncore.util.misc)

Z

ZIP (aodncore.pipeline.common.FileType attribute) (aodncore.pipeline.FileType attribute)

ZipFileResolveRunner (class in aodncore.pipeline.steps.resolve)