Skip to content

Commit fbd942f

Browse files
hugocasahugocasa
authored
fix(backend): retrieve root_job for MiniPulledJob + fix root job for flow jobs (#6490)
* feat(backend): retrieve root_job for MiniPulledJob + fix root job for flow jobs * nit * nits * set root_job only if additional information meaning if not equal to innermost or parent * nit * feat: add root job env var * nits * fix build * nit * fix build * nit * sqlx
1 parent 7df5f54 commit fbd942f

25 files changed

+230
-174
lines changed

‎backend/.sqlx/query-02c945b5f18a56a826721f6884846d79167747742de236ce57f395561685adc0.json

Lines changed: 77 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎backend/.sqlx/query-0e14ab95a08572f0672db266187335f578c622eb335cfc7cd0969633d85c9f73.json

Lines changed: 23 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎backend/.sqlx/query-b2e4dfaaee713604d0700ea4675ed2d4534e08471a60005bff85b952874c54c2.json

Lines changed: 0 additions & 71 deletions
This file was deleted.

‎backend/.sqlx/query-4aaab98ebdaa90f1edf49ac96fba6c391c4d0054a618b861464ee37239f1f1e0.json renamed to ‎backend/.sqlx/query-f3f96e066716e61042519a645d487b578bc63792cdb0f7ddaeb82e9771287c22.json

Lines changed: 16 additions & 10 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎backend/.sqlx/query-fc243af1bc70f04e28c006364d6dfdfc49981568e8c496fb6a163c499c3e4ad1.json

Lines changed: 0 additions & 23 deletions
This file was deleted.

‎backend/ee-repo-ref.txt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
d16e52d570f10dfdabb04a9061fe7ebdbf5a2aa1
1+
a5911739330d09cdc084bb277e7e3db8f8d86801

‎backend/tests/worker.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -949,6 +949,7 @@ impl RunJob {
949949
/* schedule_path */ None,
950950
/* parent_job */ None,
951951
/* root job */ None,
952+
/* flow_innermost_root_job */ None,
952953
/* job_id */ None,
953954
/* is_flow_step */ false,
954955
/* same_worker */ false,

‎backend/windmill-api/src/apps.rs

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1089,6 +1089,7 @@ async fn create_app_internal<'a>(
10891089
None,
10901090
None,
10911091
None,
1092+
None,
10921093
false,
10931094
false,
10941095
None,
@@ -1467,6 +1468,7 @@ async fn update_app_internal<'a>(
14671468
None,
14681469
None,
14691470
None,
1471+
None,
14701472
false,
14711473
false,
14721474
None,
@@ -1780,6 +1782,7 @@ async fn execute_component(
17801782
None,
17811783
None,
17821784
None,
1785+
None,
17831786
job_id,
17841787
false,
17851788
false,

‎backend/windmill-api/src/flows.rs

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -510,6 +510,7 @@ async fn create_flow(
510510
None,
511511
None,
512512
None,
513+
None,
513514
false,
514515
false,
515516
None,
@@ -977,6 +978,7 @@ async fn update_flow(
977978
None,
978979
None,
979980
None,
981+
None,
980982
false,
981983
false,
982984
None,

0 commit comments

Comments
 (0)