Skip to content

Commit ff6971f

Browse files
committed
fix(graph): use nozzle-resume header name
1 parent 02480e0 commit ff6971f

File tree

1 file changed

+6
-3
lines changed

1 file changed

+6
-3
lines changed

graph/src/amp/client/flight_client.rs

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -129,10 +129,13 @@ impl Client for FlightClient {
129129
.map(Into::into)
130130
.collect();
131131

132-
raw_client.set_header(
133-
"amp-resume",
134-
serialize_resume_streaming_query(resume_streaming_query),
132+
let metadata = serialize_resume_streaming_query(resume_streaming_query);
133+
debug!(logger, "Setting request metadata";
134+
"amp-resume" => &metadata
135135
);
136+
137+
// TODO: Update the header name when the Amp server updates to the latest version
138+
raw_client.set_header("nozzle-resume", metadata);
136139
}
137140
}
138141

0 commit comments

Comments
 (0)