fix mistype for transfer_to_address field

subsquid · Oct 22, 2024 · bf842a7 · bf842a7
1 parent 7f329c3
commit bf842a7
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 7 deletions.
diff --git a/sqa/tron/query.py b/sqa/tron/query.py
@@ -374,7 +374,7 @@ def request_name(self) -> str:
 
     def where(self, req: InternalTxRequest) -> Iterable[Expression | None]:
         yield field_in('caller_address', req.get('caller'))
-        yield field_in('transer_to_address', req.get('transferTo'))
+        yield field_in('transfer_to_address', req.get('transferTo'))
 
 
 class _InternalTxItem(Item):
@@ -389,8 +389,7 @@ def get_selected_fields(self, fields: FieldSelection) -> list[str]:
 
     def project(self, fields: FieldSelection) -> list[str]:
         return json_project(self.get_selected_fields(fields), rewrite={
-            'callValueInfo': 'call_value_info::json',
-            'transferToAddress': 'transer_to_address::text'
+            'callValueInfo': 'call_value_info::json'
         })
 
 

diff --git a/sqa/tron/writer/parquet.py b/sqa/tron/writer/parquet.py
@@ -195,7 +195,7 @@ def __init__(self):
         self.internal_transaction_index = Column(pyarrow.int32())
         self.hash = Column(pyarrow.string())
         self.caller_address = Column(pyarrow.string())
-        self.transer_to_address = Column(pyarrow.string())
+        self.transfer_to_address = Column(pyarrow.string())
         self.call_value_info = Column(JSON())
         self.note = Column(pyarrow.string())
         self.rejected = Column(pyarrow.bool_())
@@ -207,7 +207,7 @@ def append(self, block_number: int, internal_tx: InternalTransaction):
         self.internal_transaction_index.append(internal_tx['internalTransactionIndex'])
         self.hash.append(internal_tx['hash'])
         self.caller_address.append(internal_tx['callerAddress'])
-        self.transer_to_address.append(internal_tx.get('transferToAddress'))
+        self.transfer_to_address.append(internal_tx.get('transferToAddress'))
         self.call_value_info.append(_to_json(internal_tx['callValueInfo']))
         self.note.append(internal_tx['note'])
         self.rejected.append(internal_tx.get('rejected'))
@@ -312,7 +312,7 @@ def write_parquet(fs: Fs, tables: dict[str, pyarrow.Table]) -> None:
 
     internal_transactions = tables['internal_transactions']
     internal_transactions = internal_transactions.sort_by([
-        ('transer_to_address', 'ascending'),
+        ('transfer_to_address', 'ascending'),
         ('caller_address', 'ascending'),
         ('block_number', 'ascending'),
         ('internal_transaction_index', 'ascending')
@@ -328,7 +328,7 @@ def write_parquet(fs: Fs, tables: dict[str, pyarrow.Table]) -> None:
             'block_number',
             'transaction_index',
             'internal_transaction_index',
-            'transer_to_address',
+            'transfer_to_address',
             'caller_address'
         ],
         **kwargs