Skip to content

Update SDK to call Dataproxy.GetActionData#953

Open
katrogan wants to merge 3 commits intokatrina/eng26-386-sdk-create-and-cache-per-cluster-conns-for-dataproxy-svcfrom
katrina/eng26-383-ui-call-getactiondata-from-dataproxy-using-selectcluster
Open

Update SDK to call Dataproxy.GetActionData#953
katrogan wants to merge 3 commits intokatrina/eng26-386-sdk-create-and-cache-per-cluster-conns-for-dataproxy-svcfrom
katrina/eng26-383-ui-call-getactiondata-from-dataproxy-using-selectcluster

Conversation

@katrogan
Copy link
Copy Markdown
Contributor

@katrogan katrogan commented Apr 9, 2026

Which has now been deprecated in RunsService

DO NOT MERGE until BE change is in and deployed


Tested against the flyte2 demo local cluster with the prerequisite back-end changes after triggering a run:

.venv/bin/python -c "
  import asyncio, flyte
  from flyte.remote._run import Run

  async def main():
      await flyte.init_from_config.aio('.flyte/config-oss-local.yaml', project='flytesnacks', domain='development')
      run = await Run.get.aio('rjwnhmwkflr7dcr6k4rf')
      print('Run:', run.name)
      print('Phase:', run.phase)
      inputs = await run.inputs.aio()
      print('Inputs:', inputs)
      outputs = await run.outputs.aio()
      print('Outputs:', outputs)

  asyncio.run(main())
  "

  Output:
  Run: rjwnhmwkflr7dcr6k4rf
  Phase: ActionPhase.SUCCEEDED
  Inputs: {'x': 4}
  Outputs: ActionOutputs(o0=13)

if self._inputs and not self.done():
return False
resp = await get_client().run_service.get_action_data(
request=run_service_pb2.GetActionDataRequest(
Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

We will still keep this API in the run service for backward compatibility, right?

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

yup! not going to rip out for awhile

Signed-off-by: Katrina Rogan <katroganGH@gmail.com>
@katrogan katrogan changed the base branch from main to katrina/eng26-386-sdk-create-and-cache-per-cluster-conns-for-dataproxy-svc April 13, 2026 07:10
Signed-off-by: Katrina Rogan <katroganGH@gmail.com>
@katrogan katrogan force-pushed the katrina/eng26-383-ui-call-getactiondata-from-dataproxy-using-selectcluster branch from 5e475c2 to 1dc87f3 Compare April 13, 2026 07:22
…s-for-dataproxy-svc' into katrina/eng26-383-ui-call-getactiondata-from-dataproxy-using-selectcluster
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants