Skip to content

Commit 09f8bd6

Browse files
gruttCopilotabelanger5mrkaye97dependabot[bot]
authored
feat--frontend-overhaul (#1537)
* reintegration * fix: relative routes * dynamic routes * up/downgrade ui * memoize * fix breadcrumbs * cleanup * titles * title format * additional meta * cli upgrade * button * lint * Update frontend/app/src/next/components/runs/run-id.tsx Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com> * build errors * unbind on return * lint * Fe overhaul run form (#1547) * simple trigger * populated * feat:trigger modal * clear * Update frontend/app/src/next/hooks/use-runs.tsx Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com> --------- Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com> * Fe overhaul details (#1552) * simple trigger * populated * feat:trigger modal * clear * Update frontend/app/src/next/hooks/use-runs.tsx Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com> * wip activity log * merged logs * wip * wip * search box * fudge sort * wip improved worker sheet * wip * chore: improve error on dispatcher (#1538) * fix: empty billing context (#1553) * fix: empty * precommit * hotfix: priority nil pointer (#1555) * hotfix: priority on schedule workflow (#1556) * hotfix: priority on schedule workflow * fix: build * build * lint * build --------- Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com> Co-authored-by: abelanger5 <belanger@sas.upenn.edu> * Fe overhaul burndown 1 (#1563) * chore: improve error on dispatcher (#1538) * fix: empty billing context (#1553) * fix: empty * precommit * hotfix: priority nil pointer (#1555) * hotfix: priority on schedule workflow (#1556) * hotfix: priority on schedule workflow * fix: build * Hotfix: Handle EOF Properly (#1557) * fix: handle EOF properly * chore: version * fix: debug logs * fix: rm eof type * hotfix: priority on cron workflow for v0 (#1558) * fix: one more possible null deref (#1560) * Hatchet Python Blog Post (#1526) * feat: initial pass at first parts of blog post * feat: initial mkdocs setup * feat: first pass at embedding mkdocs * fix: config * debug: paths * fix: unwind docs hack * feat: start working on mkdocs theme * fix: paths * feat: wrap up post * fix: proof * fix: doc links * fix: rm docs * fix: lint * fix: lint * fix: typos + tweak * fix: tweaks * fix: typo * fix: cleanup * fix: go signature and docs (#1561) * fix: go signature and docs * Update examples/v1/workflows/concurrency-rr.go Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com> --------- Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com> * feat: toggle doc sheet * docs: concurrency cleanup (#1562) * feat: storage adapter * docs--worker-config-options (#1535) * docs--worker-config-options * Update frontend/docs/pages/home/workers.mdx Co-authored-by: abelanger5 <belanger@sas.upenn.edu> * Update worker-configuration-options.mdx * lint --------- Co-authored-by: abelanger5 <belanger@sas.upenn.edu> --------- Co-authored-by: abelanger5 <belanger@sas.upenn.edu> Co-authored-by: Matt Kaye <mrkaye97@gmail.com> Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com> * fix: bit of spacing * single generated api * feat: initial styling pass on runs views (#1586) * Feat: Workflows pages (#1577) * feat: simple workflows list page * feat: refactor + add route for individual workflow * feat: start wiring up workflow detail page --------- Co-authored-by: Gabe Ruttner <gabriel.ruttner@gmail.com> * fix: tsc * fix: compiler * fe overhaul runs bash (#1599) * wip sidebar * wip: navigation * fix nits * tweaks * clear filter button * filter on click * always scroll y * wip time filters * state changes * wip * wip * functional, no style * fix default * wip * queue metrics * multi-select * padding * counts * fix always num * actions * fix maxheight * wip * spacing * fix: tenant state * fix: tenant * lint * github page * tenant alerting * ingestors * fix: tenant state * build errrors * empty state alerter * dropdown only on mobile * billing and limits * fix form * fix form * wip * wip * env vars * wip * what a component * wip * fix inf render * cleanup * persistent tabs * wip * common actions * deploy modal * update * delete * you're a wizard harry * Feat: Subrows in Runs View (#1595) * fix: type * feat: start wiring up subrows * fix: tsc * fix: hook order * fix: hack for tsc * fix: add some margin * fix: empty state * fix: empty state centering * fix: task detail links * fix: handle error, tweak child run styling * fix: lint * fix: edge case * all mw config * wip * fix breadcrumb hook * fixes * upgrade surfaces --------- Co-authored-by: Matt Kaye <mrkaye97@gmail.com> * bring back error toast * toast improvements * lint * fix: cloud only surface * cloud surface * fix breadcrumbs * feat: config view on workflow run page (#1607) * feat: config * fix: rm schedule timeout * Feat: Rework runs sidebar (#1612) * feat: rq devtools * fix: badge hover * feat: improve sidebar * refactor: hook * fix: input undefined * feat: waterfall diagram and cleanup runs view (#1606) * merge * merge * fix merge issue * rm debug lines * case on count * fix: display names * colors and handle on click --------- Co-authored-by: mrkaye97 <mrkaye97@gmail.com> * fix: remove a ton of dead code (#1618) * fix: remove n+1 query (#1619) * Fe overhaul managed compute and onboarding (#1614) * fix tab state on state changes * fix collapsed children * setup * layout * layout * move feature * wip * chore(deps): bump k8s.io/client-go from 0.32.3 to 0.33.0 (#1608) Bumps [k8s.io/client-go](https://github.com/kubernetes/client-go) from 0.32.3 to 0.33.0. - [Changelog](https://github.com/kubernetes/client-go/blob/master/CHANGELOG.md) - [Commits](kubernetes/client-go@v0.32.3...v0.33.0) --- updated-dependencies: - dependency-name: k8s.io/client-go dependency-version: 0.33.0 dependency-type: direct:production update-type: version-update:semver-minor ... Signed-off-by: dependabot[bot] <support@github.com> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> * wip * universal install * initial migration guide * fakefake tokens * fake secret * fixes * lint * lint * lint * tidy * chore: expose clean docs on top level * drop reo * wip * static * functional * bump go 1.23 -> 1.24 * fix: whitespace lint * bump golangci-lint version * wip * try to set up go before pre commit runs * lint * names * lint * fix: session store * wip * normalized snips * fix links * blog: mergent migration (#1611) * universal install * initial migration guide * fakefake tokens * fake secret * fixes * lint * lint * lint * tidy * bump go 1.23 -> 1.24 * fix: whitespace lint * bump golangci-lint version * try to set up go before pre commit runs * lint * names * lint * fix: session store * fix links --------- Co-authored-by: Alexander Belanger <alexander@hatchet.run> * reusable state * fix: rm unimplemented pages for now (#1615) * feature dir * fixes (#1616) * with public auth * completed typescript flow * go blocks * wip * layout * wip * feat: read replica support and docs (#1617) * feat: read replica support and docs * fix: load logic * wip * wip * remove provider * migrate to static * fix block * lint * fix: loadtest * add task for linting * cleanup * fix meta sync * clean examples with highlights * get snips into app * sync * remove fake highlights * always gen before build * ignore generated * ignore * ignore generated * cleanup * always start the dev server * examples dependabot * app examples built off sdk examples * auto sync on main changes * sync the quickstarts with updating dependencies * examples and quickstart dependabots * only examples * functional onboarding * fix worker detail page * fix detail page * lint * init * tested structure copy * prepend * ❓to >, ‼️ to !! * normalize * separate example source * multi source * with index * wip * clean generation * migrated * cleanup * should build * sync before build * fix steps * inline * mkdirs * revert build * gen docs * static * rm * update examples * lint * fix: ts * fix remove lines on match * fix: client * add snips * dont lint examples * fix source * dont test examples * exclude quickstart * lint * dont break examples * cleanup * cleanup --------- Signed-off-by: dependabot[bot] <support@github.com> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> Co-authored-by: Alexander Belanger <alexander@hatchet.run> Co-authored-by: Matt Kaye <mrkaye97@gmail.com> Co-authored-by: abelanger5 <belanger@sas.upenn.edu> * Merge main * lint * fix * Update api-server-setup.mdx * cleanup * github state * review and build --------- Signed-off-by: dependabot[bot] <support@github.com> Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com> Co-authored-by: abelanger5 <belanger@sas.upenn.edu> Co-authored-by: Matt Kaye <mrkaye97@gmail.com> Co-authored-by: Alexander Belanger <alexander@hatchet.run> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
1 parent 31bb907 commit 09f8bd6

File tree

331 files changed

+34741
-497
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

331 files changed

+34741
-497
lines changed

‎.gitignore

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -31,6 +31,8 @@ node_modules
3131
# Jetbrains IDEs
3232
*.iml
3333

34+
.eslintcache
35+
3436
# Local docs directories
3537
/docs/.obsidian
3638

‎.pre-commit-config.yaml

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3,13 +3,19 @@ repos:
33
rev: v4.5.0
44
hooks:
55
- id: check-merge-conflict
6+
exclude: ^examples/
67
- id: mixed-line-ending
78
args: ["--fix=lf"]
9+
exclude: ^examples/
810
- id: end-of-file-fixer
11+
exclude: ^examples/
912
- id: trailing-whitespace
13+
exclude: ^examples/
1014
- id: check-yaml
15+
exclude: ^examples/
1116
- repo: https://github.com/golangci/golangci-lint
1217
rev: v2.1.3
1318
hooks:
1419
- id: golangci-lint
1520
args: ["--config=.golangci.yml"]
21+
exclude: ^examples/

‎api-contracts/openapi/components/schemas/workflow.yaml

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -25,9 +25,13 @@ Workflow:
2525
items:
2626
$ref: "#/Job"
2727
description: The jobs of the workflow.
28+
tenantId:
29+
type: string
30+
description: The tenant id of the workflow.
2831
required:
2932
- metadata
3033
- name
34+
- tenantId
3135
type: object
3236

3337
WorkflowUpdateRequest:

‎api/v1/server/oas/gen/openapi.gen.go

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

‎api/v1/server/oas/transformers/workflow.go

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -12,13 +12,15 @@ func ToWorkflow(
1212
workflow *dbsqlc.Workflow,
1313
version *dbsqlc.WorkflowVersion,
1414
) *gen.Workflow {
15+
1516
res := &gen.Workflow{
1617
Metadata: *toAPIMetadata(
1718
sqlchelpers.UUIDToStr(workflow.ID),
1819
workflow.CreatedAt.Time,
1920
workflow.UpdatedAt.Time,
2021
),
21-
Name: workflow.Name,
22+
Name: workflow.Name,
23+
TenantId: sqlchelpers.UUIDToStr(workflow.TenantId),
2224
}
2325

2426
res.IsPaused = &workflow.IsPaused.Bool

‎examples/go/workflows/on-cron.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -43,3 +43,4 @@ func OnCron(hatchet v1.HatchetClient) workflow.WorkflowDeclaration[OnCronInput,
4343

4444
return cronTask
4545
}
46+

‎examples/go/workflows/priority.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -49,3 +49,4 @@ func Priority(hatchet v1.HatchetClient) workflow.WorkflowDeclaration[PriorityInp
4949
)
5050
return workflow
5151
}
52+

‎examples/go/workflows/ratelimit.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -93,3 +93,4 @@ func RateLimit(hatchet v1.HatchetClient) workflow.WorkflowDeclaration[RateLimitI
9393

9494
return rateLimitTask
9595
}
96+

‎examples/go/z_v0/cron/main.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -81,3 +81,4 @@ func main() {
8181

8282
// ,
8383
}
84+

‎examples/go/z_v0/on-failure/main.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -105,3 +105,4 @@ func main() {
105105
}
106106
// ,
107107
}
108+

‎examples/go/z_v0/retries-with-backoff/main.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -95,3 +95,4 @@ func main() {
9595

9696
// ,
9797
}
98+

‎examples/python/child/simple-fanout.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -17,3 +17,5 @@ async def spawn(input: EmptyModel, ctx: Context) -> dict[str, Any]:
1717
)
1818

1919
return {"results": result}
20+
21+

‎examples/python/logger/client.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -15,3 +15,4 @@
1515
logger=root_logger,
1616
),
1717
)
18+

‎examples/python/logger/workflow.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -37,3 +37,5 @@ def context_logger(input: EmptyModel, ctx: Context) -> dict[str, str]:
3737
time.sleep(0.1)
3838

3939
return {"status": "success"}
40+
41+

‎examples/python/manual_slot_release/worker.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -19,3 +19,5 @@ def step1(input: EmptyModel, ctx: Context) -> dict[str, str]:
1919

2020
print("NON RESOURCE INTENSIVE PROCESS")
2121
return {"status": "success"}
22+
23+

‎examples/typescript/on_event copy/event.ts

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

‎examples/typescript/on_event copy/worker.ts

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

‎examples/typescript/on_event copy/workflow.ts

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

‎frontend/app/.eslintrc.json

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,9 +16,15 @@
1616
"ignorePatterns": ["dist"],
1717
"parser": "@typescript-eslint/parser",
1818
"parserOptions": {
19-
"project": ["./tsconfig.json", "./tsconfig.node.json"]
19+
"project": ["./tsconfig.json", "./tsconfig.node.json"],
20+
"warnOnUnsupportedTypeScriptVersion": false
2021
},
2122
"plugins": ["react-refresh", "import", "unused-imports", "prettier"],
23+
"settings": {
24+
"react": {
25+
"version": "18.3.1"
26+
}
27+
},
2228
"rules": {
2329
"@typescript-eslint/no-shadow": "off",
2430
"@typescript-eslint/no-throw-literal": "off",

‎frontend/app/package.json

Lines changed: 9 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -5,22 +5,25 @@
55
"type": "module",
66
"packageManager": "pnpm@9.15.4",
77
"scripts": {
8-
"dev": "vite",
8+
"dev": "npm run sync-docs && npm run sync-examples && vite",
99
"build": "tsc && vite build",
1010
"lint:check": "npm run eslint:check && npm run prettier:check",
1111
"lint:fix": "npm run eslint:fix && npm run prettier:fix",
1212
"eslint:check": "eslint \"{src,apps,libs,test}/**/*.{ts,tsx,js}\"",
1313
"eslint:fix": "eslint \"{src,apps,libs,test}/**/*.{ts,tsx,js}\" --fix",
1414
"prettier:check": "prettier \"src/**/*.{ts,tsx}\" --list-different",
1515
"prettier:fix": "prettier \"src/**/*.{ts,tsx}\" --write",
16-
"preview": "vite preview"
16+
"preview": "vite preview",
17+
"sync-docs": "tsx src/next/lib/docs/sync-docs.ts && eslint \"src/next/lib/docs/generated/**/*.{ts,tsx,js}\" --fix --cache && prettier \"src/next/lib/docs/generated/**/*.{ts,tsx}\" --write",
18+
"sync-examples": "cd ../snips/ && pnpm i && pnpm generate && pnpm run copy:app"
1719
},
1820
"dependencies": {
1921
"@heroicons/react": "^2.2.0",
2022
"@hookform/resolvers": "^3.10.0",
2123
"@lukemorales/query-key-factory": "^1.3.4",
2224
"@monaco-editor/react": "^4.7.0",
2325
"@radix-ui/react-accordion": "^1.2.3",
26+
"@radix-ui/react-alert-dialog": "^1.1.7",
2427
"@radix-ui/react-avatar": "^1.1.3",
2528
"@radix-ui/react-checkbox": "^1.1.4",
2629
"@radix-ui/react-collapsible": "^1.1.3",
@@ -46,6 +49,7 @@
4649
"@sentry/react": "^7.120.3",
4750
"@sentry/vite-plugin": "^2.23.0",
4851
"@tanstack/react-query": "^5.71.1",
52+
"@tanstack/react-query-devtools": "^5.74.6",
4953
"@tanstack/react-table": "^8.21.2",
5054
"@visx/axis": "^3.12.0",
5155
"@visx/brush": "^3.12.0",
@@ -88,6 +92,7 @@
8892
"react-syntax-highlighter": "^15.6.1",
8993
"reactflow": "^11.11.4",
9094
"recharts": "^2.15.1",
95+
"shiki": "^3.2.2",
9196
"tailwind-merge": "^2.6.0",
9297
"tailwindcss-animate": "^1.0.7",
9398
"timeago-react": "^3.0.7",
@@ -120,6 +125,8 @@
120125
"prettier": "^3.5.3",
121126
"swagger-typescript-api": "^13.0.28",
122127
"tailwindcss": "^3.4.17",
128+
"ts-unused-exports": "^11.0.1",
129+
"tsx": "^4.19.3",
123130
"typescript": "^5.8.2",
124131
"vite": "^6.2.4",
125132
"vite-plugin-eslint": "^1.8.1"

0 commit comments

Comments
 (0)