Skip to content

[DOP-26806] Add child jobs and runs#399

Open
TiGrib wants to merge 1 commit intodevelopfrom
feature/DOP-26806
Open

[DOP-26806] Add child jobs and runs#399
TiGrib wants to merge 1 commit intodevelopfrom
feature/DOP-26806

Conversation

@TiGrib
Copy link
Contributor

@TiGrib TiGrib commented Mar 6, 2026

Change Summary

Add child runs and jobs to lineage.

Related issue number

[DOP-26806]

Checklist

  • Commit message and PR title is comprehensive
  • Keep the change as small as possible
  • Unit and integration tests for the changes exist
  • Tests pass on CI and coverage does not decrease
  • Documentation reflects the changes where applicable
  • docs/changelog/next_release/<pull request or issue id>.<change type>.rst file added describing change
    (see CONTRIBUTING.rst for details.)
  • My PR is ready to review.

@TiGrib TiGrib requested a review from dolfinus March 6, 2026 15:20
@TiGrib TiGrib self-assigned this Mar 6, 2026
@github-actions
Copy link

github-actions bot commented Mar 6, 2026

Coverage

Coverage Report •
FileStmtsMissBranchBrPartCoverMissing
data_rentgen/db/repositories
   job.py110532495%335–337, 341, 347
   run.py13430481477%280–281, 283–284, 286, 288, 296, 299–300, 302–303, 310–311, 314–317, 320–321, 324, 341–343, 351, 370–372, 374–375, 407
data_rentgen/server/services
   lineage.py491262041594%86, 104, 262, 293, 469, 499, 635, 666, 739–741, 756, 1162, 1227, 1315, 1317–1320, 1351–1357
TOTAL7657964120421587% 

)
return list(result.fetchall())

async def list_jobs_child_relations(self, job_ids: Collection[int]):
Copy link
Member

Choose a reason for hiding this comment

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

Suggested change
async def list_jobs_child_relations(self, job_ids: Collection[int]):
async def list_descendant_relations(self, job_ids: Collection[int]):

)
return list(result.fetchall())

async def list_runs_child_relations(self, run_ids: Collection[UUID]):
Copy link
Member

Choose a reason for hiding this comment

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

Suggested change
async def list_runs_child_relations(self, run_ids: Collection[UUID]):
async def list_descendant_relations(self, run_ids: Collection[UUID]):

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