Skip to content
This repository has been archived by the owner on Dec 18, 2024. It is now read-only.

Commit

Permalink
Linting
Browse files Browse the repository at this point in the history
  • Loading branch information
giancarloaf committed Feb 11, 2024
1 parent f32b412 commit 8923e9f
Showing 1 changed file with 4 additions and 2 deletions.
6 changes: 4 additions & 2 deletions modules/tech_report_pipeline.py
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,8 @@


def technology_hash_id(element: dict, query_type: str, key_map=constants.TECHNOLOGY_QUERY_ID_KEYS):
"""Returns a hashed id for a set of technology query keys. Keys are sorted alphabetically and joined with a dash. The resulting string is hashed using SHA256."""
"""Returns a hashed id for a set of technology query keys. Keys are sorted alphabetically and joined with a dash.
The resulting string is hashed using SHA256."""
if query_type not in key_map:
raise ValueError(f"Invalid query type: {query_type}")
keys = sorted(key_map[query_type])
Expand Down Expand Up @@ -52,7 +53,8 @@ def convert_decimal_to_float(data):


class WriteToFirestoreDoFn(beam.DoFn):
"""Write a single element to Firestore. Yields the hash id of the document. Retry on failure using exponential backoff, see :func:`apache_beam.utils.retry.with_exponential_backoff`."""
"""Write a single element to Firestore. Yields the hash id of the document.
Retry on failure using exponential backoff, see :func:`apache_beam.utils.retry.with_exponential_backoff`."""
def __init__(self, project, database, collection, query_type):
self.client = None
self.project = project
Expand Down

0 comments on commit 8923e9f

Please sign in to comment.