academic_observatory_workflows.pubmed_telescope.release ======================================================= .. py:module:: academic_observatory_workflows.pubmed_telescope.release Classes ------- .. autoapisummary:: academic_observatory_workflows.pubmed_telescope.release.PubMedRelease Module Contents --------------- .. py:class:: PubMedRelease(*, dag_id: str, run_id: str, cloud_workspace: observatory_platform.airflow.workflow.CloudWorkspace, bq_dataset_id: str, start_date: pendulum.DateTime, end_date: pendulum.DateTime, year_first_run: bool, datafile_list: List[academic_observatory_workflows.pubmed_telescope.datafile.Datafile], baseline_upload_date: pendulum.DateTime) Bases: :py:obj:`observatory_platform.airflow.release.ChangefileRelease` .. py:attribute:: cloud_workspace .. py:attribute:: bq_dataset_id .. py:attribute:: year_first_run .. py:attribute:: datafile_list .. py:attribute:: baseline_upload_date .. py:attribute:: datafile_release .. py:method:: schema_file_path(record_type: str) -> str .. py:method:: transfer_blob_pattern(table_type: str) -> str Create a blob pattern for importing the transformed unmerged records from GCS into Bigquery. :param table_type: Type of the record. :return: Uri pattern for transformed files. .. py:property:: baseline_files :type: List[academic_observatory_workflows.pubmed_telescope.datafile.Datafile] Return a list of the "baseline" datafiles files for this release. .. py:property:: updatefiles :type: List[academic_observatory_workflows.pubmed_telescope.datafile.Datafile] Return a list of "updatefile" datafiles for this release. .. py:property:: merged_upsert_uri_blob_pattern :type: str Create a uri blob pattern for importing the transformed merged upserts from GCS into Bigquery. :return: Uri pattern for merged transform files. .. py:property:: merged_delete_transfer_uri :type: str Create a uri for importing the transformed merged deletes from GCS into Bigquery. :return: uri for merged transform files. .. py:property:: merged_delete_file_path .. py:method:: from_dict(dict_: dict) -> PubMedRelease :staticmethod: .. py:method:: to_dict() -> dict