cuddly-jelly-27016
05/31/2025, 12:10 AMflytekit, the web UI lets me see its state - which of the nodes (n0 , n1 , ...) are running, which succeeded, which failed).
### Provide a possible output or UX example
import flytekit
import flytekit.remote
config = flytekit.configuration.Config.auto("config.yml")
r = flytekit.remote.FlyteRemote(config)
wf: FlyteWorkflowExecution = r.launch_backfill(
project=project,
domain=domain,
from_date=part.from_date,
to_date=part.to_date,
launchplan=launchplan,
launchplan_version=launchplan_version,
execution_name=execution_name,
)
"""
# Internal structure of the wf object:
{
"id": {
"project": "marketplace--pa--dags--bpo-ltv-model",
"domain": "dprod",
"name": "f34c31c37272c492f928" # execution id
},
"spec": {
"launchPlan": {
"resourceType": "LAUNCH_PLAN",
"project": "marketplace--pa--dags--bpo-ltv-model",
"domain": "dprod",
"name": "backfill-bpo_ltv_90d_horizon_1d_observation",
"version": "bbGJcfQA6wmPZNIqAmHHSg==" # of the launchplan - these dates
},
"metadata": {
"principal": "ChUxMDgwMzg0MjQ4NDE3Nzc0Mzg5MzgSBmdvb2dsZQ",
"systemMetadata": {}
},
"notifications": {},
"labels": {},
"annotations": {},
"securityContext": {
"runAs": {}
},
"authRole": {}
},
"closure": {
"startedAt": "1970-01-01T000000Z",
"duration": "0s",
"createdAt": "2023-12-19T092627.169745Z",
"updatedAt": "2023-12-19T092627.169745Z"
}
}
"""
r.fetch_workflow_execeution_status(project, domain, name)
# should provide the node-level information - something that
# r.fetch_execution is missing.
### Are you sure this issue hasn't been raised already?
• Yes
### Have you read the Code of Conduct?
• Yes
flyteorg/flytecuddly-jelly-27016
05/31/2025, 12:10 AM