Skip to content

Commit

Permalink
refactor: Removed write limit
Browse files Browse the repository at this point in the history
  • Loading branch information
Bhargav Dodla committed Feb 5, 2025
1 parent 5076bd6 commit c74d4f3
Showing 1 changed file with 0 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,6 @@
"""

import logging
import time
from datetime import datetime
from typing import Any, Callable, Dict, List, Literal, Optional, Sequence, Tuple

Expand Down Expand Up @@ -353,7 +352,6 @@ def online_write_batch(
display progress.
"""
write_concurrency = config.online_store.write_concurrency
write_limit = 1.0 / write_concurrency
project = config.project
ttl = (
table.online_store_key_ttl_seconds
Expand Down Expand Up @@ -388,7 +386,6 @@ def online_write_batch(
)
batch.add(insert_cql, params)
futures.append(session.execute_async(batch))
time.sleep(write_limit)

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

0 comments on commit c74d4f3

Please sign in to comment.