Skip to content

Commit

Permalink
fix: increase waiting times
Browse files Browse the repository at this point in the history
  • Loading branch information
ali-bahjati committed Sep 17, 2024
1 parent 0a96456 commit ada3d98
Showing 1 changed file with 9 additions and 9 deletions.
18 changes: 9 additions & 9 deletions integration-tests/tests/test_integration.py
Original file line number Diff line number Diff line change
Expand Up @@ -515,11 +515,11 @@ async def test_update_price_simple(self, client: PythAgentClient):

# Send an "update_price" request
await client.update_price(price_account, 42, 2, "trading")
time.sleep(2)
time.sleep(5)

# Send another "update_price" request to trigger aggregation
await client.update_price(price_account, 81, 1, "trading")
time.sleep(2)
time.sleep(5)

# Confirm that the price account has been updated with the values from the first "update_price" request
final_product_state = await client.get_product(product_account)
Expand Down Expand Up @@ -701,13 +701,13 @@ async def test_agent_respects_market_hours(self, client: PythAgentClient):

# Send an "update_price" request
await client.update_price(price_account, 42, 2, "trading")
time.sleep(2)
time.sleep(5)

# Send another update_price request to "trigger" aggregation
# (aggregation would happen if market hours were to fail, but
# we want to catch that happening if there's a problem)
await client.update_price(price_account, 81, 1, "trading")
time.sleep(2)
time.sleep(5)

# Confirm that the price account has not been updated
final_product_state = await client.get_product(product_account)
Expand Down Expand Up @@ -736,13 +736,13 @@ async def test_agent_respects_holiday_hours(self, client: PythAgentClient):

# Send an "update_price" request
await client.update_price(price_account, 42, 2, "trading")
time.sleep(2)
time.sleep(5)

# Send another update_price request to "trigger" aggregation
# (aggregation would happen if market hours were to fail, but
# we want to catch that happening if there's a problem)
await client.update_price(price_account, 81, 1, "trading")
time.sleep(2)
time.sleep(5)

# Confirm that the price account has not been updated
final_product_state = await client.get_product(product_account)
Expand Down Expand Up @@ -772,13 +772,13 @@ async def test_agent_respects_publish_interval(self, client: PythAgentClient):

# Send an "update_price" request
await client.update_price(price_account, 42, 2, "trading")
time.sleep(1)
time.sleep(5)

# Send another update_price request to "trigger" aggregation
# (aggregation would happen if publish interval were to fail, but
# we want to catch that happening if there's a problem)
await client.update_price(price_account, 81, 1, "trading")
time.sleep(2)
time.sleep(5)

# Confirm that the price account has not been updated
final_product_state = await client.get_product(product_account)
Expand All @@ -792,7 +792,7 @@ async def test_agent_respects_publish_interval(self, client: PythAgentClient):
# Send another update_price request to "trigger" aggregation
# Now it is after the publish interval, so the price should be updated
await client.update_price(price_account, 81, 1, "trading")
time.sleep(2)
time.sleep(5)

# Confirm that the price account has been updated
final_product_state = await client.get_product(product_account)
Expand Down

0 comments on commit ada3d98

Please sign in to comment.