Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

AIP-84 Get Mapped Task Instance Tries #44303

Open
wants to merge 7 commits into
base: main
Choose a base branch
from

Conversation

kandharvishnu
Copy link
Contributor

related to: #42370


@boring-cyborg boring-cyborg bot added area:API Airflow's REST/HTTP API area:UI Related to UI/UX. For Frontend Developers. labels Nov 23, 2024
@rawwar rawwar added the legacy api Whether legacy API changes should be allowed in PR label Nov 23, 2024
@kandharvishnu kandharvishnu force-pushed the AIP-84_get_mapped_task_instance_tries branch from 1b5e318 to 3c81dd4 Compare November 23, 2024 13:10
Comment on lines +273 to +279
task_instances = [
TaskInstanceHistoryResponse.model_validate(task_instance, from_attributes=True)
for task_instance in task_instance_select
]
return TaskInstanceHistoryCollectionResponse(
task_instances=task_instances,
total_entries=len(task_instances),
)
Copy link
Collaborator

Choose a reason for hiding this comment

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

Suggested change
task_instances = [
TaskInstanceHistoryResponse.model_validate(task_instance, from_attributes=True)
for task_instance in task_instance_select
]
return TaskInstanceHistoryCollectionResponse(
task_instances=task_instances,
total_entries=len(task_instances),
)
return TaskInstanceHistoryCollectionResponse(
task_instances=task_instance_select,
total_entries=len(task_instance_select),
)

Copy link
Contributor Author

@kandharvishnu kandharvishnu Nov 23, 2024

Choose a reason for hiding this comment

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

TaskInstanceHistoryCollectionResponse will take the list of TaskInstanceHistoryResponse.

As a first step, I am changing the airflow.models.taskinstance.TaskInstance to TaskInstanceHistoryResponse and then passing it to TaskInstanceHistoryCollectionResponse

Copy link
Collaborator

Choose a reason for hiding this comment

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

can you use cast like here:

task_instances=cast(list[TaskInstanceResponse], task_instances),

Copy link
Collaborator

Choose a reason for hiding this comment

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

If this doesn't work. please close this conversation.

@kandharvishnu kandharvishnu force-pushed the AIP-84_get_mapped_task_instance_tries branch from 3c81dd4 to a22e190 Compare November 23, 2024 14:02
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
area:API Airflow's REST/HTTP API area:UI Related to UI/UX. For Frontend Developers. legacy api Whether legacy API changes should be allowed in PR
Projects
None yet
Development

Successfully merging this pull request may close these issues.

3 participants