refactor(ark-db): indexer table

ArkProjectNFTs · Sep 7, 2023 · 2db9d26 · 2db9d26
1 parent 6a4f777
commit 2db9d26
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/crates/ark-db/src/indexer/update.rs b/crates/ark-db/src/indexer/update.rs
@@ -23,7 +23,7 @@ pub async fn update_indexer(
         .put_item()
         .table_name(indexer_table_name)
         .item("PK", AttributeValue::S(String::from("INDEXER")))
-        .item("SK", AttributeValue::S(task_id.to_string()))
+        .item("SK", AttributeValue::S(format!("TASK#{}", task_id)))
         .item("status", AttributeValue::S(status))
         .item("last_update", AttributeValue::N(unix_timestamp.to_string()))
         .item("version", AttributeValue::S(indexer_version))
@@ -57,7 +57,7 @@ pub async fn update_block(dynamo_client: &Client, task_id: &str, block_number: u
         .put_item()
         .table_name(indexer_table_name)
         .item("PK", AttributeValue::S(format!("BLOCK#{}", block_number)))
-        .item("SK", AttributeValue::S(task_id.to_string()))
+        .item("SK", AttributeValue::S(format!("TASK#{}", task_id)))
         .item("is_fetched", AttributeValue::Bool(true))
         .item("last_update", AttributeValue::N(unix_timestamp.to_string()))
         .item("indexer", AttributeValue::S(task_id.to_string()))