From 1c76d2fb1db7e34089f5f4806e0016a76d13b850 Mon Sep 17 00:00:00 2001 From: Andrey Dolgolev Date: Fri, 8 Oct 2021 04:01:19 +0300 Subject: [PATCH] Add fixes. --- datasets/nfts/nfts/cli.py | 4 ++-- datasets/nfts/nfts/derive.py | 34 +++++++++++++++++----------------- 2 files changed, 19 insertions(+), 19 deletions(-) diff --git a/datasets/nfts/nfts/cli.py b/datasets/nfts/nfts/cli.py index 2ad43ae4..4111ccdd 100644 --- a/datasets/nfts/nfts/cli.py +++ b/datasets/nfts/nfts/cli.py @@ -16,7 +16,7 @@ from .derive import ( current_market_values, current_values_distribution, transfer_statistics_by_address, - qurtile_generating, + quartile_generating, mint_holding_times, transfer_holding_times, transfers_mints_connection_table, @@ -33,7 +33,7 @@ derive_functions = { "current_market_values": current_market_values, "current_values_distribution": current_values_distribution, "transfer_statistics_by_address": transfer_statistics_by_address, - "qurtile_generating": qurtile_generating, + "quartile_generating": quartile_generating, "transfers_mints_connection_table": transfers_mints_connection_table, "mint_holding_times": mint_holding_times, "transfer_holding_times": transfer_holding_times, diff --git a/datasets/nfts/nfts/derive.py b/datasets/nfts/nfts/derive.py index d9b760e8..65b4d421 100644 --- a/datasets/nfts/nfts/derive.py +++ b/datasets/nfts/nfts/derive.py @@ -51,8 +51,8 @@ class LastNonzeroValue: class QuartileFunction: """ Split vlues to quartiles """ - def __init__(self, num_qurtiles) -> None: - self.divider = 1 / num_qurtiles + def __init__(self, num_quartiles) -> None: + self.divider = 1 / num_quartiles def __call__(self, value): if value is None or value == "None": @@ -63,9 +63,9 @@ class QuartileFunction: quartile += self.divider if quartile > 1: - qurtile = 1 + quartile = 1 - return qurtile + return quartile except Exception as err: print(err) @@ -218,19 +218,19 @@ def transfer_statistics_by_address(conn: sqlite3.Connection) -> None: logger.error(e) -def qurtile_generating(conn: sqlite3.Connection): +def quartile_generating(conn: sqlite3.Connection): """ - Create qurtile wich depends on setted on class defenition + Create quartile wich depends on setted on class defenition """ ensure_custom_aggregate_functions(conn) - drop_calculate_10_qurtiles = ( + drop_calculate_10_quartiles = ( "DROP TABLE IF EXISTS transfer_values_quartile_10_distribution_per_address;" ) - calculate_10_qurtiles = """ + calculate_10_quartiles = """ CREATE TABLE transfer_values_quartile_10_distribution_per_address AS select cumulate.address as address, - CAST(quartile_10(cumulate.relative_value) as TEXT) as qurtiles, + CAST(quartile_10(cumulate.relative_value) as TEXT) as quartiles, cumulate.relative_value as relative_value from ( @@ -254,14 +254,14 @@ def qurtile_generating(conn: sqlite3.Connection): ) as cumulate """ - drop_calculate_25_qurtiles = ( + drop_calculate_25_quartiles = ( "DROP TABLE IF EXISTS transfer_values_quartile_10_distribution_per_address;" ) - calculate_25_qurtiles = """ + calculate_25_quartiles = """ CREATE TABLE transfer_values_quartile_10_distribution_per_address AS select cumulate.address as address, - CAST(quartile_25(cumulate.relative_value) as TEXT) as qurtiles, + CAST(quartile_25(cumulate.relative_value) as TEXT) as quartiles, cumulate.relative_value as relative_value from ( @@ -288,15 +288,15 @@ def qurtile_generating(conn: sqlite3.Connection): cur = conn.cursor() try: print("Creating transfer_values_quartile_10_distribution_per_address") - cur.execute(drop_calculate_10_qurtiles) - cur.execute(calculate_10_qurtiles) + cur.execute(drop_calculate_10_quartiles) + cur.execute(calculate_10_quartiles) print("Creating transfer_values_quartile_25_distribution_per_address") - cur.execute(drop_calculate_25_qurtiles) - cur.execute(calculate_25_qurtiles) + cur.execute(drop_calculate_25_quartiles) + cur.execute(calculate_25_quartiles) conn.commit() except Exception as e: conn.rollback() - logger.error("Could not create derived dataset: qurtile_generating") + logger.error("Could not create derived dataset: quartile_generating") logger.error(e)