You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Idea is something along the lines of the code block shown below. Things to consider:
Support both "read-only sources" (things which always respond 200 and are used in defining other responses)
Support "read/write sources" (things which compute responses using kaskada)
It's OK if this only works with the new partitioned execution code paths (eg., using the Source / Destination traits).
# this produces `{ request_id: i64, data: <schema> }`
source = kd.sources.Http(
schema = ...,
# Optional response. This allows for requests that append data.
# If not specified, then a later `run_and_respond` is necessary.
respond_with = 200,
)
output = kd.record({
request_id: source.request_id,
x_plus_y = source.data.x + source.data.y,
)}
source.run_and_respond(
# Use Kaskada to define responses.
respond_with = output,
# Report a warning if the output is not available
# for a request within this timelimit.
# this may happen if the request gets buffered in
# a shift, etc.
timelimit = 1s
)
The text was updated successfully, but these errors were encountered:
Idea is something along the lines of the code block shown below. Things to consider:
It's OK if this only works with the new partitioned execution code paths (eg., using the
Source
/Destination
traits).The text was updated successfully, but these errors were encountered: