diff options
| author | Pinapelz <yukais@pinapelz.com> | 2025-05-01 17:53:12 -0700 |
|---|---|---|
| committer | Pinapelz <yukais@pinapelz.com> | 2025-05-01 17:54:02 -0700 |
| commit | a69e258b3a8ff8f029a94ef9722bdb6f0f9173db (patch) | |
| tree | 24cab0bd15a80664dc0f39d517bf4cbecc5c3f4f /nijitrack.py | |
| parent | a54cdbc23873e5785485b4e8caf416de0142d0b5 (diff) | |
remove. dangerous table deletion. adjust pg_handler insert row to update on channel_id conflict
Diffstat (limited to 'nijitrack.py')
| -rw-r--r-- | nijitrack.py | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/nijitrack.py b/nijitrack.py index 13e5ef9..fd2c76b 100644 --- a/nijitrack.py +++ b/nijitrack.py @@ -55,7 +55,7 @@ def record_subscriber_data(data: list, force_refresh: bool = False): elif refresh_daily: server.update_row(DATA_SETTING["TABLE_DAILY"], "channel_id", channel_id, "sub_diff", sub_count) server.insert_row(table_name = DATA_SETTING["TABLE_HISTORICAL"], column = DATA_SETTING["HISTORICAL_HEADER"], data=data_tuple) - + def check_diff_refresh(): last_updated = server.get_most_recently_added_row_time(DATA_SETTING["TABLE_HISTORICAL"]) if last_updated is None or len(last_updated) == 0 or not last_updated[0]: @@ -107,7 +107,6 @@ def holodex_generation(server: PostgresHandler, force_refresh: bool = False): Generates the data from the Holodex API """ holodex_organizations = DATA_SETTING["HOLODEX_ORGS"].split(",") - server.clear_table(DATA_SETTING["TABLE_LIVE"]) holodex = HolodexAPI(os.environ.get("HOLODEX_KEY"), organization="Phase%20Connect") for organization in holodex_organizations: holodex.set_organization(organization) @@ -179,4 +178,4 @@ if __name__ == "__main__": if args.b2: uploadFileToBucket("index.html") else: - print("Skipping B2 Upload")
\ No newline at end of file + print("Skipping B2 Upload") |