Skip to content

Commit

Permalink
Remove debug logging
Browse files Browse the repository at this point in the history
  • Loading branch information
rculbertson committed Jan 16, 2025
1 parent d38d0b7 commit 61cf07b
Showing 1 changed file with 0 additions and 2 deletions.
2 changes: 0 additions & 2 deletions modal/_utils/async_utils.py
Original file line number Diff line number Diff line change
Expand Up @@ -283,10 +283,8 @@ async def put(self, timestamp: float, item: Union[T, None]):
"""
Add an item to the queue to be processed at a specific timestamp.
"""
print(f"QUEUE PUT putting {timestamp} {item}")
await self._queue.put((timestamp, item))
async with self.condition:
print("QUEUE PUT notifying")
self.condition.notify_all() # notify any waiting coroutines

async def get(self) -> Union[T, None]:
Expand Down

0 comments on commit 61cf07b

Please sign in to comment.