🐛 fix(basic_example.json): change value of "value" key from "abc" to null to remove hardcoded value and improve flexibility
✅ test(test_user.py): add test to create a super user for testing purposes and ensure it returns the correct response 🔥 chore(utils.py): remove unused functions run_post and poll_task_status to clean up code
This commit is contained in:
parent
59b62aae17
commit
416d294117
3 changed files with 4 additions and 29 deletions
|
|
@ -1,27 +0,0 @@
|
|||
import time
|
||||
|
||||
|
||||
def run_post(client, flow_id, headers, post_data):
|
||||
response = client.post(
|
||||
f"api/v1/process/{flow_id}",
|
||||
headers=headers,
|
||||
json=post_data,
|
||||
)
|
||||
assert response.status_code == 200, response.json()
|
||||
return response.json()
|
||||
|
||||
|
||||
# Helper function to poll task status
|
||||
def poll_task_status(client, headers, task_id, max_attempts=20, sleep_time=1):
|
||||
for _ in range(max_attempts):
|
||||
task_status_response = client.get(
|
||||
f"api/v1/task/{task_id}/status",
|
||||
headers=headers,
|
||||
)
|
||||
if (
|
||||
task_status_response.status_code == 200
|
||||
and task_status_response.json()["status"] == "SUCCESS"
|
||||
):
|
||||
return task_status_response.json()
|
||||
time.sleep(sleep_time)
|
||||
return None # Return None if task did not complete in time
|
||||
Loading…
Add table
Add a link
Reference in a new issue