Developer Documentation

• kuha_common
  • server.py
    • log_request()
    • str_api_endpoint()
    • serve()
    • RequestHandler
      • RequestHandler.prepare()
      • RequestHandler.correlation_id
      • RequestHandler.set_output_content_type()
      • RequestHandler.log_exception()
      • RequestHandler.assert_request_content_type()
      • RequestHandler.get_valid_query_arguments()
      • RequestHandler.write_error()
    • WebApplication
    • InvalidContentType
    • BadRequest
    • ResourceNotFound
    • Conflict
  • query.py
    • ResultHandler
    • QueryController
      • QueryController.fk_constants
      • QueryController.query_single()
      • QueryController.query_multiple()
      • QueryController.query_count()
      • QueryController.query_distinct()
  • conf.py
    • CommandLineParseException
    • KuhaConfigFileParser
      • KuhaConfigFileParser.get_syntax_description()
    • load()
    • add()
    • get()
    • add_conf()
    • get_conf()
    • print_conf()
  • cli_setup.py
    • MOD_DS_CLIENT
    • MOD_DS_QUERY
    • MOD_SERVER
    • MOD_LOGGING
    • add_logging_configs()
    • setup_logging()
    • setup_common_modules()
  • document_store
  • document_store/client.py
    • JSONStreamClient
      • JSONStreamClient.sleep_on_queue
      • JSONStreamClient.request()
      • JSONStreamClient.wrap_streaming_callback()
      • JSONStreamClient.execute_stored_callbacks()
      • JSONStreamClient.run_queued_requests()
      • JSONStreamClient.get_streaming_request()
      • JSONStreamClient.queue_request()
      • JSONStreamClient.fetch()
  • document_store/query.py
    • FilterKeyConstants
    • QueryException
    • Query
      • Query.k_filter
      • Query.k_fields
      • Query.k_limit
      • Query.k_skip
      • Query.k_sort_order
      • Query.k_sort_by
      • Query.k_fieldname
      • Query.query_type_select
      • Query.query_type_count
      • Query.query_type_distinct
      • Query.as_supported_datetime_str()
      • Query.construct()
      • Query.construct_distinct()
      • Query.build_query_for_date_range()
      • Query.build_query_for_exists()
      • Query.get_valid_params()
      • Query.get_required_params()
      • Query.is_valid_query()
      • Query.is_valid_query_type()
      • Query.is_valid_query_document()
      • Query.is_valid_param()
      • Query.validate_query()
      • Query.validate_query_type()
      • Query.validate_query_document()
      • Query.get_endpoint()
      • Query.get_query()
      • Query.get_limit()
      • Query.get_skip()
      • Query.set_limit()
      • Query.set_skip()
      • Query.set_fields()
      • Query.set_sort_by()
      • Query.set_sort_order()
      • Query.set_query_type()
      • Query.add_query_statement()
      • Query.add_query_statements()
  • document_store/field_types.py
    • FieldTypeException
    • Value
      • Value.set_value()
      • Value.add_value()
      • Value.get_value()
      • Value.get_name()
      • Value.export_dict()
      • Value.import_records()
      • Value.updates()
    • Set
      • Set.set_value()
      • Set.add_value()
      • Set.import_records()
      • Set.updates()
    • Element
      • Element.is_pending()
      • Element.new()
      • Element.add_value()
      • Element.iterate_attributes()
      • Element.get_attribute()
      • Element.export_attributes_as_dict()
      • Element.export_dict()
      • Element.import_records()
      • Element.updates()
    • LocalizableElement
      • LocalizableElement.set_language()
      • LocalizableElement.get_language()
      • LocalizableElement.add_value()
      • LocalizableElement.export_dict()
    • ElementContainer
      • ElementContainer.import_records()
      • ElementContainer.add_value()
      • ElementContainer.export_dict()
      • ElementContainer.iterate_values_for_language()
      • ElementContainer.get_available_languages()
      • ElementContainer.updates()
    • FieldAttribute
      • FieldAttribute.value_from_dict()
    • FieldTypeFactory
      • FieldTypeFactory.fabricate()
  • document_store/records.py
    • datetime_to_datestamp()
    • datestamp_to_datetime()
    • datetime_now()
    • path_split()
    • path_join()
    • dig_and_set()
    • RecordBase
      • RecordBase.get_collection()
      • RecordBase.iterate_record_fields()
      • RecordBase.export_metadata_dict()
      • RecordBase.export_dict()
      • RecordBase.set_updated()
      • RecordBase.set_created()
      • RecordBase.set_deleted()
      • RecordBase.set_cmm_type()
      • RecordBase.set_id()
      • RecordBase.get_updated()
      • RecordBase.get_created()
      • RecordBase.get_deleted()
      • RecordBase.get_id()
      • RecordBase.is_deleted()
      • RecordBase.bypass_update()
      • RecordBase.bypass_create()
      • RecordBase.updates_record()
      • RecordBase.updates()
    • Study
      • Study.study_number
      • Study.persistent_identifiers
      • Study.identifiers
      • Study.study_titles
      • Study.document_titles
      • Study.parallel_titles
      • Study.principal_investigators
      • Study.publishers
      • Study.distributors
      • Study.document_uris
      • Study.study_uris
      • Study.publication_dates
      • Study.publication_years
      • Study.distribution_dates
      • Study.abstract
      • Study.classifications
      • Study.keywords
      • Study.time_methods
      • Study.sampling_procedures
      • Study.collection_modes
      • Study.analysis_units
      • Study.research_instruments
      • Study.collection_periods
      • Study.data_kinds
      • Study.study_area_countries
      • Study.geographic_coverages
      • Study.universes
      • Study.data_access
      • Study.data_access_descriptions
      • Study.citation_requirements
      • Study.deposit_requirements
      • Study.file_names
      • Study.instruments
      • Study.related_publications
      • Study.study_groups
      • Study.copyrights
      • Study.data_collection_copyrights
      • Study.funding_agencies
      • Study.grant_numbers
      • Study.collection
      • Study.cmm_type
      • Study.add_study_number()
      • Study.add_persistent_identifiers()
      • Study.add_identifiers()
      • Study.add_study_titles()
      • Study.add_document_titles()
      • Study.add_parallel_titles()
      • Study.add_principal_investigators()
      • Study.add_publishers()
      • Study.add_distributors()
      • Study.add_document_uris()
      • Study.add_study_uris()
      • Study.add_publication_dates()
      • Study.add_publication_years()
      • Study.add_distribution_dates()
      • Study.add_abstract()
      • Study.add_classifications()
      • Study.add_keywords()
      • Study.add_time_methods()
      • Study.add_sampling_procedures()
      • Study.add_collection_modes()
      • Study.add_analysis_units()
      • Study.add_research_instruments()
      • Study.add_collection_periods()
      • Study.add_data_kinds()
      • Study.add_study_area_countries()
      • Study.add_geographic_coverages()
      • Study.add_universes()
      • Study.add_data_access()
      • Study.add_data_access_descriptions()
      • Study.add_citation_requirements()
      • Study.add_deposit_requirements()
      • Study.add_file_names()
      • Study.add_instruments()
      • Study.add_related_publications()
      • Study.add_study_groups()
      • Study.add_copyrights()
      • Study.add_data_collection_copyrights()
      • Study.add_funding_agencies()
      • Study.add_grant_numbers()
      • Study.add_document_description_notes()
      • Study.updates()
    • Variable
      • Variable.study_number
      • Variable.variable_name
      • Variable.question_identifiers
      • Variable.variable_labels
      • Variable.codelist_codes
      • Variable.collection
      • Variable.cmm_type
      • Variable.add_study_number()
      • Variable.add_variable_name()
      • Variable.add_question_identifiers()
      • Variable.add_variable_labels()
      • Variable.add_codelist_codes()
      • Variable.updates()
    • Question
      • Question.study_number
      • Question.question_identifier
      • Question.variable_name
      • Question.question_texts
      • Question.research_instruments
      • Question.codelist_references
      • Question.collection
      • Question.cmm_type
      • Question.add_study_number()
      • Question.add_question_identifier()
      • Question.add_variable_name()
      • Question.add_question_texts()
      • Question.add_research_instruments()
      • Question.add_codelist_references()
      • Question.updates()
    • StudyGroup
      • StudyGroup.study_group_identifier
      • StudyGroup.study_group_names
      • StudyGroup.descriptions
      • StudyGroup.uris
      • StudyGroup.study_numbers
      • StudyGroup.collection
      • StudyGroup.cmm_type
      • StudyGroup.add_study_group_identifier()
      • StudyGroup.add_study_group_names()
      • StudyGroup.add_descriptions()
      • StudyGroup.add_uris()
      • StudyGroup.add_study_numbers()
      • StudyGroup.updates()
    • record_factory()
    • record_by_collection()
  • document_store/mappings
  • document_store/mappings/exceptions.py
    • InvalidMapperParameters
    • MappingError
    • ParseError
    • UnknownXMLRoot
    • MissingRequiredAttribute
    • InvalidContent
  • document_store/mappings/xmlbase.py
    • MappedParams
      • MappedParams.has_language()
      • MappedParams.set_language()
      • MappedParams.get_language()
      • MappedParams.get_value()
      • MappedParams.copy()
      • MappedParams.has_arguments()
    • XMLMapper
      • XMLMapper.set_value_conversion()
      • XMLMapper.set_value_getter()
      • XMLMapper.expect_single_value()
      • XMLMapper.expect_multiple_values()
      • XMLMapper.disable_attributes()
      • XMLMapper.iterate_attributes()
      • XMLMapper.as_params()
      • XMLMapper.add_attribute()
      • XMLMapper.value_params()
      • XMLMapper.values_params()
    • XMLParserBase
      • XMLParserBase.NS
      • XMLParserBase.default_language
      • XMLParserBase.from_string()
      • XMLParserBase.from_file()
      • XMLParserBase.child_text()
      • XMLParserBase.root_element
      • XMLParserBase.root_language
      • XMLParserBase.study_number
      • XMLParserBase.study_number_identifier
      • XMLParserBase.studies
      • XMLParserBase.variables
      • XMLParserBase.questions
      • XMLParserBase.study_groups
      • XMLParserBase.all
      • XMLParserBase.select()
    • as_valid_identifier()
    • str_equals()
    • fixed_value()
    • element_remove_whitespaces()
    • element_strip_descendant_text()
    • element_strip_descendant_text_by_tag()
    • get_preferred_publication_id_agency_pair()
  • document_store/mappings/ddi
  • document_store/mappings/ddi/codebook.py
    • DDI122RecordParser
      • DDI122RecordParser.studies
      • DDI122RecordParser.variables
      • DDI122RecordParser.questions
      • DDI122RecordParser.study_groups
    • DDI122NesstarRecordParser
    • DDI25RecordParser
      • DDI25RecordParser.NS
  • document_store/mappings/ddi/lifecycle.py
    • DDILifecycleParserBase
      • DDILifecycleParserBase.variables
      • DDILifecycleParserBase.questions
      • DDILifecycleParserBase.study_groups
    • DDILifecycle32ParserBase
      • DDILifecycle32ParserBase.studies
  • document_store/mappings/ddi/ddi31.py
    • DDI31RecordParser
      • DDI31RecordParser.NS
      • DDI31RecordParser.studies
  • document_store/mappings/ddi/ddi33.py
    • DDI33RecordParser
      • DDI33RecordParser.NS
  • testing
    • time_me()
    • mock_coro()
    • MockCoro()
  • testing/testcases.py
    • KuhaUnitTestCase
      • KuhaUnitTestCase.dummydata_dir
      • KuhaUnitTestCase.setUpClass()
      • KuhaUnitTestCase.tearDownClass()
      • KuhaUnitTestCase.get_dummydata_path()
      • KuhaUnitTestCase.get_dummydata()
      • KuhaUnitTestCase.remove_dummyfile_if_exists()
      • KuhaUnitTestCase.set_val()
      • KuhaUnitTestCase.gen_val()
      • KuhaUnitTestCase.gen_id()
      • KuhaUnitTestCase.generate_dummy_study()
      • KuhaUnitTestCase.generate_dummy_variable()
      • KuhaUnitTestCase.generate_dummy_question()
      • KuhaUnitTestCase.generate_dummy_studygroup()
      • KuhaUnitTestCase.run_until_complete()
      • KuhaUnitTestCase.setUp()
      • KuhaUnitTestCase.tearDown()
      • KuhaUnitTestCase.await_and_store_result()
      • KuhaUnitTestCase.init_patcher()
      • KuhaUnitTestCase.assert_records_are_equal()
      • KuhaUnitTestCase.assert_records_are_not_equal()
      • KuhaUnitTestCase.assert_mock_meth_has_calls()
    • KuhaEndToEndTestCase
      • KuhaEndToEndTestCase.setUpClass()
      • KuhaEndToEndTestCase.tearDownClass()
      • KuhaEndToEndTestCase.get_record_url()
      • KuhaEndToEndTestCase.get_query_url()
      • KuhaEndToEndTestCase.GET_to_document_store()
      • KuhaEndToEndTestCase.POST_to_document_store()
      • KuhaEndToEndTestCase.DELETE_to_document_store()
      • KuhaEndToEndTestCase.query_document_store()
      • KuhaEndToEndTestCase.get_collection_record_count()
      • KuhaEndToEndTestCase.assert_document_store_is_empty()
• kuha_document_store
  • serve.py
    • get_app()
    • main()
  • handlers.py
    • BaseHandler
      • BaseHandler.prepare()
      • BaseHandler.get_db()
      • BaseHandler.assert_body_not_empty()
    • RestApiHandler
      • RestApiHandler.get()
      • RestApiHandler.post()
      • RestApiHandler.put()
      • RestApiHandler.delete()
    • QueryHandler
      • QueryHandler.prepare()
      • QueryHandler.post()
  • database.py
    • Collection
      • Collection.indexes
      • Collection.indexes_unique
      • Collection.isodate_fields
      • Collection.name
      • Collection.object_id_fields
      • Collection.validators
    • mongodburi()
    • bson_to_json()
    • Database
      • Database.close()
      • Database.query_single()
      • Database.query_multiple()
      • Database.query_distinct()
      • Database.count()
      • Database.insert()
      • Database.replace()
      • Database.insert_or_replace()
      • Database.update()
      • Database.delete()
    • DocumentStoreDatabase
      • DocumentStoreDatabase.recoverable_errors
      • DocumentStoreDatabase.json_decode()
      • DocumentStoreDatabase.query_multiple()
      • DocumentStoreDatabase.query_by_oid()
      • DocumentStoreDatabase.query_distinct()
      • DocumentStoreDatabase.insert_json()
      • DocumentStoreDatabase.replace_json()
      • DocumentStoreDatabase.delete_records()
    • db_from_settings()
    • add_cli_args()
  • validation.py
    • RecordValidator
      • RecordValidator.validate()
    • RecordValidationError
    • RecordValidationSchema
      • RecordValidationSchema.get_schema()
    • validate()
  • dbadmin
  • dbadmin/operations.py
    • OperationsSetup
    • DEFAULT_ARBITER_INDEX
• kuha_oai_pmh_repo_hander
  • constants.py
  • serve.py
    • KuhaEntryPointException
    • InvalidMetadataFormatException
    • ConflictingMetadataPrefixException
    • NoMetadataFormatsException
    • load_metadataformats()
    • configure()
    • main()
  • controller.py
    • Controller
      • Controller.oai_error()
      • Controller.identify()
      • Controller.listsets()
      • Controller.listmetadataformats()
      • Controller.listidentifiers()
      • Controller.listrecords()
      • Controller.getrecord()
      • Controller.oai_request()
    • from_settings()
    • add_cli_args()
  • genshi_loader.py
    • FOLDERS
    • add_template_folders()
    • get_template_folders()
    • KuhaXMLSerializer
    • GenPlate
      • GenPlate.set_stylesheet_url()
  • http_api.py
    • OAIRouteHandler
      • OAIRouteHandler.prepare()
      • OAIRouteHandler.write_output()
      • OAIRouteHandler.get()
      • OAIRouteHandler.post()
    • get_app()
  • list_records.py
    • InvalidOAIResponse
    • main()
  • metadataformats
    • DuplicateSetSpec
    • MDFormat
      • MDFormat.overridable
      • MDFormat.study_class
      • MDFormat.variable_class
      • MDFormat.question_class
      • MDFormat.MDSet
        • MDFormat.MDSet.add_cli_args()
        • MDFormat.MDSet.configure()
        • MDFormat.MDSet.fields()
        • MDFormat.MDSet.filter()
        • MDFormat.MDSet.get()
        • MDFormat.MDSet.query()
      • MDFormat.add_cli_args()
      • MDFormat.configure_sets()
      • MDFormat.configure()
      • MDFormat.get_deleted_record()
      • MDFormat.get_set()
      • MDFormat.get_earliest_datestamp()
      • MDFormat.list_sets()
      • MDFormat.list_identifiers()
      • MDFormat.list_metadata_formats()
      • MDFormat.get_record()
      • MDFormat.list_records()
    • DCMetadataFormat
      • DCMetadataFormat.overridable
      • DCMetadataFormat.add_cli_args()
      • DCMetadataFormat.configure()
      • DCMetadataFormat.get_record()
      • DCMetadataFormat.list_records()
    • EAD3MetadataFormat
      • EAD3MetadataFormat.overridable
      • EAD3MetadataFormat.add_cli_args()
      • EAD3MetadataFormat.configure()
      • EAD3MetadataFormat.get_record()
      • EAD3MetadataFormat.list_records()
      • EAD3MetadataFormat.get_daterange_pairs()
      • EAD3MetadataFormat.get_singledates()
    • DDICMetadataFormat
      • DDICMetadataFormat.overridable
      • DDICMetadataFormat.add_cli_args()
      • DDICMetadataFormat.configure()
      • DDICMetadataFormat.get_record()
      • DDICMetadataFormat.list_records()
    • OAIDDI25MetadataFormat
      • OAIDDI25MetadataFormat.overridable
      • OAIDDI25MetadataFormat.add_cli_args()
      • OAIDDI25MetadataFormat.configure()
      • OAIDDI25MetadataFormat.get_record()
      • OAIDDI25MetadataFormat.list_records()
    • OAIDataciteMetadataFormat
      • OAIDataciteMetadataFormat.overridable
      • OAIDataciteMetadataFormat.add_cli_args()
      • OAIDataciteMetadataFormat.configure()
      • OAIDataciteMetadataFormat.get_preferred_identifier()
      • OAIDataciteMetadataFormat.get_related_identifiers_types()
      • OAIDataciteMetadataFormat.get_publisher_lang_value_pair()
      • OAIDataciteMetadataFormat.get_funders()
      • OAIDataciteMetadataFormat.get_record()
      • OAIDataciteMetadataFormat.list_records()
  • metadataformats/const.py
  • metadataformats/exc.py
    • NoSuchSet
  • metadataformats/_mdsets.py
    • MDSet
      • MDSet.add_cli_args()
      • MDSet.configure()
      • MDSet.fields()
      • MDSet.query()
      • MDSet.get()
      • MDSet.filter()
    • LanguageSet
      • LanguageSet.fields()
      • LanguageSet.query()
      • LanguageSet.get()
      • LanguageSet.filter()
    • StudyGroupsSet
      • StudyGroupsSet.fields()
      • StudyGroupsSet.query()
      • StudyGroupsSet.get()
      • StudyGroupsSet.filter()
    • DataKindSet
      • DataKindSet.fields()
      • DataKindSet.query()
      • DataKindSet.get()
      • DataKindSet.filter()
    • OpenAIREDataSet
      • OpenAIREDataSet.fields()
      • OpenAIREDataSet.query()
      • OpenAIREDataSet.get()
      • OpenAIREDataSet.filter()
  • oai
  • oai/errors.py
    • OAIError
      • OAIError.get_code()
      • OAIError.get_msg()
      • OAIError.get_context()
      • OAIError.get_contextual_message()
    • MissingVerb
    • BadVerb
    • NoMetadataFormats
    • IdDoesNotExist
    • BadArgument
    • CannotDisseminateFormat
    • NoRecordsMatch
    • BadResumptionToken
    • NoSetHierarchy
  • oai/constants.py
    • REGEX_OAI_IDENTIFIER
    • REGEX_SETSPEC
  • oai/protocol.py
    • REGEX_VALID_SETSPEC
    • is_valid_setspec()
    • as_supported_datetime()
    • as_supported_datestring()
    • Response
      • Response.set_repository_name()
      • Response.set_base_url()
      • Response.set_admin_email()
      • Response.set_protocol_version()
      • Response.identify_response()
      • Response.add_available_metadata_format()
      • Response.set_error()
      • Response.add_sets_element()
      • Response.set_request_args()
    • ResumptionToken
      • ResumptionToken.Attribute
        • ResumptionToken.Attribute.key
        • ResumptionToken.Attribute.value
      • ResumptionToken.load_arg()
      • ResumptionToken.encoded
    • Arguments
      • Arguments.supported_verbs
      • Arguments.resumable_verbs
      • Arguments.is_verb_resumable()
      • Arguments.get_local_identifier()
      • Arguments.is_selective()
• kuha_osmh_repo_handler
  • serve.py
    • get_app()
    • main()
  • configure.py
    • configure()
  • handlers.py
    • BaseHandler
      • BaseHandler.prepare()
    • ListRecordHeadersHandler
      • ListRecordHeadersHandler.prepare()
      • ListRecordHeadersHandler.get()
    • GetRecordHandler
      • GetRecordHandler.get()
    • ListSupportedRecordTypesHandler
      • ListSupportedRecordTypesHandler.get()
    • SupportedVersionsHandler
      • SupportedVersionsHandler.get()
  • response.py
    • RecordsResponse
      • RecordsResponse.iterate_records()
      • RecordsResponse.get_record_appender()
      • RecordsResponse.get_payload_appender()
      • RecordsResponse.get_response()
      • RecordsResponse.get_single_response()
  • osmh
  • osmh/records.py
    • Payload
      • Payload.join_values()
      • Payload.split_value()
      • Payload.insert()
      • Payload.insert_localized_value()
      • Payload.append()
      • Payload.header()
      • Payload.get()
    • OSMHRecord
      • OSMHRecord.osmh_type
      • OSMHRecord.query_document
      • OSMHRecord.relative_queries_for_record
      • OSMHRecord.fields_for_header()
      • OSMHRecord.fields_for_record()
      • OSMHRecord.query_filter_for_record()
      • OSMHRecord.for_header_response()
      • OSMHRecord.for_record_response()
      • OSMHRecord.get_query_document()
      • OSMHRecord.requires_relative_queries_for_record()
      • OSMHRecord.build_header_payload()
      • OSMHRecord.build_record_payload()
      • OSMHRecord.get_payload()
    • StudyRecord
      • StudyRecord.query_document
      • StudyRecord.fields_for_header()
      • StudyRecord.fields_for_record()
      • StudyRecord.query_filter_for_record()
      • StudyRecord.get_secondary_query_fields_for_record()
      • StudyRecord.get_secondary_query_document()
      • StudyRecord.get_secondary_query_filter_for_record()
      • StudyRecord.build_relative_record_payload()
      • StudyRecord.build_record_payload()
    • VariableRecord
      • VariableRecord.query_document
      • VariableRecord.fields_for_header()
      • VariableRecord.fields_for_record()
      • VariableRecord.query_filter_for_record()
      • VariableRecord.build_record_payload()
    • QuestionRecord
      • QuestionRecord.query_document
      • QuestionRecord.fields_for_header()
      • QuestionRecord.fields_for_record()
      • QuestionRecord.query_filter_for_record()
      • QuestionRecord.build_record_payload()
    • StudyGroupRecord
      • StudyGroupRecord.query_document
      • StudyGroupRecord.fields_for_header()
      • StudyGroupRecord.fields_for_record()
      • StudyGroupRecord.query_filter_for_record()
      • StudyGroupRecord.build_record_payload()
    • get_osmh_record_for_type()
• kuha_client
  • SourceFile
    • SourceFile.add_id()
    • SourceFile.list_ids()
  • Cache
    • Cache.has_loaded_paths
    • Cache.has_results
    • Cache.invalidate()
    • Cache.register_collection()
    • Cache.registered_collections
    • Cache.get_processed_ids_for_collection()
    • Cache.result()
    • Cache.print_summary()
    • Cache.load_file()
    • Cache.unload_file()
    • Cache.forget_file()
  • FileLoggingCache
    • FileLoggingCache.remove_lost_files()
    • FileLoggingCache.invalidate()
    • FileLoggingCache.save()
    • FileLoggingCache.result()
    • FileLoggingCache.load_file()
    • FileLoggingCache.unload_file()
    • FileLoggingCache.has_cached_results_for_collection()
  • open_file_logging_cache()
  • DocumentStoreHTTPError
  • send_create_record_request()
  • send_update_record_request()
  • send_delete_record_request()
  • iterate_xml_directory()
  • iterate_xml_files_recursively()
  • CollectionMethods
    • CollectionMethods.prepare_for_upsert_run()
    • CollectionMethods.query_record()
    • CollectionMethods.query_distinct_ids()
    • CollectionMethods.remove_records()
    • CollectionMethods.remove_record_by_id()
    • CollectionMethods.upsert()
    • CollectionMethods.create_record()
    • CollectionMethods.update_record()
  • NoSuchCollectionMethod
  • BatchProcessor
    • BatchProcessor.upsert_from_parser()
    • BatchProcessor.upsert_paths()
    • BatchProcessor.remove_absent()
    • BatchProcessor.remove_absent_records()
    • BatchProcessor.remove_records()
    • BatchProcessor.upsert_run()
    • BatchProcessor.remove_run()
    • BatchProcessor.print_summary()
  • impl.py
    • StudyMethods
      • StudyMethods.query_record()
      • StudyMethods.query_distinct_ids()
      • StudyMethods.remove_record_by_id()
    • VariableMethods
      • VariableMethods.query_record()
      • VariableMethods.query_distinct_ids()
    • QuestionMethods
      • QuestionMethods.query_record()
      • QuestionMethods.query_distinct_ids()
    • StudyGroupMethods
      • StudyGroupMethods.query_record()
      • StudyGroupMethods.query_distinct_ids()
      • StudyGroupMethods.really_upsert()
      • StudyGroupMethods.upsert()
      • StudyGroupMethods.remove_records_with_no_study_numbers()
    • collection_methods()
    • StudyGroupsBatchProcessor
      • StudyGroupsBatchProcessor.upsert_paths()
      • StudyGroupsBatchProcessor.remove_absent_records()
  • sync.py
    • get_proc()
    • configure()
    • cli()
  • kuha_delete.py
    • cli()