Skip to content

Commit c74d4f3

Browse files
author
Bhargav Dodla
committed
refactor: Removed write limit
1 parent 5076bd6 commit c74d4f3

File tree

1 file changed

+0
-3
lines changed

1 file changed

+0
-3
lines changed

sdk/python/feast/infra/online_stores/contrib/cassandra_online_store/cassandra_online_store.py

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,6 @@
1919
"""
2020

2121
import logging
22-
import time
2322
from datetime import datetime
2423
from typing import Any, Callable, Dict, List, Literal, Optional, Sequence, Tuple
2524

@@ -353,7 +352,6 @@ def online_write_batch(
353352
display progress.
354353
"""
355354
write_concurrency = config.online_store.write_concurrency
356-
write_limit = 1.0 / write_concurrency
357355
project = config.project
358356
ttl = (
359357
table.online_store_key_ttl_seconds
@@ -388,7 +386,6 @@ def online_write_batch(
388386
)
389387
batch.add(insert_cql, params)
390388
futures.append(session.execute_async(batch))
391-
time.sleep(write_limit)
392389

393390
# TODO: Make this efficient by leveraging continuous writes rather
394391
# than blocking until all writes are done. We may need to rate limit

0 commit comments

Comments
 (0)