academic_observatory_workflows.unpaywall_telescope.release
==========================================================

.. py:module:: academic_observatory_workflows.unpaywall_telescope.release


Classes
-------

.. autoapisummary::

   academic_observatory_workflows.unpaywall_telescope.release.Changefile
   academic_observatory_workflows.unpaywall_telescope.release.UnpaywallRelease


Module Contents
---------------

.. py:class:: Changefile(filename: str, changefile_date: pendulum.DateTime, changefile_release: observatory_platform.airflow.release.ChangefileRelease = None)

   .. py:attribute:: filename


   .. py:attribute:: changefile_date


   .. py:attribute:: changefile_release
      :value: None



   .. py:method:: __eq__(other)


   .. py:method:: from_dict(dict_: Dict) -> Changefile
      :staticmethod:



   .. py:method:: to_dict() -> Dict


   .. py:property:: download_file_path


   .. py:property:: extract_file_path


   .. py:property:: transform_file_path


.. py:class:: UnpaywallRelease(*, dag_id: str, run_id: str, cloud_workspace: observatory_platform.airflow.workflow.CloudWorkspace, bq_dataset_id: str, bq_table_name: str, is_first_run: bool, snapshot_date: pendulum.DateTime, changefiles: List[Changefile], prev_end_date: pendulum.DateTime)

   Bases: :py:obj:`observatory_platform.airflow.release.Release`


   .. py:attribute:: cloud_workspace


   .. py:attribute:: bq_dataset_id


   .. py:attribute:: bq_table_name


   .. py:attribute:: is_first_run


   .. py:attribute:: snapshot_date


   .. py:attribute:: snapshot_release


   .. py:attribute:: changefile_release


   .. py:attribute:: changefiles


   .. py:attribute:: prev_end_date


   .. py:attribute:: snapshot_download_file_path


   .. py:attribute:: snapshot_extract_file_path


   .. py:attribute:: main_table_file_path


   .. py:attribute:: upsert_table_file_path


   .. py:attribute:: main_table_files_regex
      :value: '^main_table\\d{12}\\.jsonl$'



   .. py:attribute:: main_table_uri


   .. py:attribute:: upsert_table_uri


   .. py:attribute:: bq_main_table_id


   .. py:attribute:: bq_upsert_table_id


   .. py:attribute:: bq_snapshot_table_id


   .. py:method:: from_dict(dict_: dict) -> UnpaywallRelease
      :staticmethod:



   .. py:method:: to_dict() -> dict