Skip to content

Commit

Permalink
Added comments via TODO where user changes needed
Browse files Browse the repository at this point in the history
  • Loading branch information
justinpolygon committed Jan 11, 2024
1 parent 0c0f5fd commit 0e37a49
Showing 1 changed file with 4 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -20,6 +20,9 @@ async def start_processing_api_calls(self):
while True:
options_ticker = await self.api_call_queue.get()
try:
# TODO:
# Here, you can process the rest api requets as needed
# Example: Get the options contract for this
contract = await asyncio.get_running_loop().run_in_executor(
self.executor, self.get_options_contract, options_ticker
)
Expand Down Expand Up @@ -47,6 +50,7 @@ async def start_handling(self) -> None:
message_response = await self.handler_queue.get()
logging.info(f"Received message: {message_response}")
try:
# TODO:
# Here, you can process the websocket messages as needed
# Example: Extract ticker symbol and enqueue REST API call
# to get the options contract for this trade (non-blocking)
Expand Down

0 comments on commit 0e37a49

Please sign in to comment.