Skip to content

Commit

Permalink
Add printout of query id
Browse files Browse the repository at this point in the history
  • Loading branch information
raunakab committed Feb 6, 2025
1 parent 5e7e2bc commit 45a4459
Showing 1 changed file with 3 additions and 1 deletion.
4 changes: 3 additions & 1 deletion daft/dataframe/dataframe.py
Original file line number Diff line number Diff line change
Expand Up @@ -190,15 +190,17 @@ def _explain_broadcast(self):
plan_time_end = datetime.now(timezone.utc)

try:
id = uuid4()
requests.post(
f"http://{addr}:{port}",
json={
"id": str(uuid4()),
"id": str(id),
"mermaid-plan": mermaid_plan,
"plan-time-start": str(plan_time_start),
"plan-time-end": str(plan_time_end),
},
)
print(f"Query ID: {id}")
except requests.exceptions.ConnectionError as conn_error:
warnings.warn(
"Unable to broadcast daft query plan over http."
Expand Down

0 comments on commit 45a4459

Please sign in to comment.