Skip to content

Commit 55aac41

Browse files
committed
feat: continuing with argo workflow agent
1 parent 40f6e4f commit 55aac41

5 files changed

Lines changed: 358 additions & 299 deletions

File tree

apps/api/src/routes/argoworkflow/workflow.ts

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,7 @@ export const mapTriggerToStatus = (trigger: string): JobStatus | null =>
3535
export const handleArgoWorkflow = async (payload: ArgoWorkflowPayload) => {
3636
const { workflowName, uid, phase, startedAt, finishedAt } = payload;
3737

38-
const jobId = uid;
38+
const jobId = extractUuid(workflowName);
3939
if (jobId == null) return;
4040

4141
const status = statusMap[phase] ?? null;
@@ -50,7 +50,7 @@ export const handleArgoWorkflow = async (payload: ArgoWorkflowPayload) => {
5050
.set({
5151
externalId: uid,
5252
status,
53-
startedAt: new Date(startedAt),
53+
...(startedAt ? { startedAt: new Date(startedAt) } : {}),
5454
completedAt,
5555
updatedAt: new Date(),
5656
})

apps/workspace-engine/go.mod

Lines changed: 48 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -1,10 +1,11 @@
11
module workspace-engine
22

3-
go 1.25.5
3+
go 1.25.7
44

55
require (
66
github.com/Masterminds/sprig/v3 v3.3.0
77
github.com/argoproj/argo-cd/v3 v3.3.4
8+
github.com/argoproj/argo-workflows/v4 v4.0.3
89
github.com/avast/retry-go v2.7.0+incompatible
910
github.com/charmbracelet/log v0.4.2
1011
github.com/confluentinc/confluent-kafka-go/v2 v2.13.3
@@ -96,9 +97,9 @@ require (
9697
go.uber.org/mock v0.6.0 // indirect
9798
golang.org/x/arch v0.20.0 // indirect
9899
golang.org/x/crypto v0.48.0 // indirect
99-
golang.org/x/mod v0.32.0 // indirect
100+
golang.org/x/mod v0.33.0 // indirect
100101
golang.org/x/sync v0.19.0
101-
golang.org/x/tools v0.41.0 // indirect
102+
golang.org/x/tools v0.42.0 // indirect
102103
google.golang.org/genproto/googleapis/api v0.0.0-20260209200024-4cfbd4190f57 // indirect
103104
google.golang.org/genproto/googleapis/rpc v0.0.0-20260209200024-4cfbd4190f57 // indirect
104105
google.golang.org/grpc v1.79.1 // indirect
@@ -109,6 +110,7 @@ require (
109110
cloud.google.com/go/compute/metadata v0.9.0 // indirect
110111
cyphar.com/go-pathrs v0.2.1 // indirect
111112
dario.cat/mergo v1.0.2 // indirect
113+
filippo.io/edwards25519 v1.1.1 // indirect
112114
github.com/Azure/azure-sdk-for-go/sdk/azcore v1.20.0 // indirect
113115
github.com/Azure/azure-sdk-for-go/sdk/azidentity v1.13.1 // indirect
114116
github.com/Azure/azure-sdk-for-go/sdk/internal v1.11.2 // indirect
@@ -119,8 +121,9 @@ require (
119121
github.com/Masterminds/semver/v3 v3.4.0 // indirect
120122
github.com/Microsoft/go-winio v0.6.2 // indirect
121123
github.com/ProtonMail/go-crypto v1.3.0 // indirect
124+
github.com/argoproj/argo-events v1.9.6 // indirect
122125
github.com/argoproj/gitops-engine v0.7.1-0.20250908182407-97ad5b59a627 // indirect
123-
github.com/argoproj/pkg v0.13.7-0.20230626144333-d56162821bd1 // indirect
126+
github.com/argoproj/pkg v0.13.7-0.20250123033407-65f2d4777bfd // indirect
124127
github.com/argoproj/pkg/v2 v2.0.1 // indirect
125128
github.com/aymanbagabas/go-osc52/v2 v2.0.1 // indirect
126129
github.com/beorn7/perks v1.0.1 // indirect
@@ -140,26 +143,30 @@ require (
140143
github.com/charmbracelet/x/term v0.2.1 // indirect
141144
github.com/clipperhouse/stringish v0.1.1 // indirect
142145
github.com/clipperhouse/uax29/v2 v2.3.0 // indirect
143-
github.com/cloudflare/circl v1.6.1 // indirect
146+
github.com/cloudflare/circl v1.6.3 // indirect
147+
github.com/colinmarc/hdfs/v2 v2.4.0 // indirect
144148
github.com/containerd/containerd/api v1.10.0 // indirect
145149
github.com/coreos/go-oidc/v3 v3.17.0 // indirect
146-
github.com/creack/pty v1.1.24 // indirect
147150
github.com/cyphar/filepath-securejoin v0.6.1 // indirect
148151
github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f // indirect
149152
github.com/distribution/reference v0.6.0 // indirect
150153
github.com/dlclark/regexp2 v1.11.5 // indirect
154+
github.com/doublerebel/bellows v0.0.0-20160303004610-f177d92a03d3 // indirect
151155
github.com/dustin/go-humanize v1.0.1 // indirect
152156
github.com/emicklei/go-restful/v3 v3.13.0 // indirect
153157
github.com/emirpasic/gods v1.18.1 // indirect
154158
github.com/evanphx/json-patch/v5 v5.9.11 // indirect
159+
github.com/evilmonkeyinc/jsonpath v0.8.1 // indirect
155160
github.com/exponent-io/jsonpath v0.0.0-20210407135951-1de76d718b3f // indirect
161+
github.com/expr-lang/expr v1.17.7 // indirect
156162
github.com/fatih/camelcase v1.0.0 // indirect
157163
github.com/felixge/httpsnoop v1.0.4 // indirect
158164
github.com/fxamacker/cbor/v2 v2.9.0 // indirect
159165
github.com/go-errors/errors v1.5.1 // indirect
160166
github.com/go-git/gcfg v1.5.1-0.20230307220236-3a3c6141e376 // indirect
161167
github.com/go-git/go-billy/v5 v5.6.2 // indirect
162-
github.com/go-git/go-git/v5 v5.14.0 // indirect
168+
github.com/go-git/go-git/v5 v5.16.5 // indirect
169+
github.com/go-jose/go-jose/v3 v3.0.4 // indirect
163170
github.com/go-jose/go-jose/v4 v4.1.3 // indirect
164171
github.com/go-logfmt/logfmt v0.6.0 // indirect
165172
github.com/go-openapi/swag/cmdutils v0.25.3 // indirect
@@ -174,10 +181,12 @@ require (
174181
github.com/go-openapi/swag/typeutils v0.25.3 // indirect
175182
github.com/go-openapi/swag/yamlutils v0.25.3 // indirect
176183
github.com/go-redis/cache/v9 v9.0.0 // indirect
177-
github.com/gobwas/glob v0.2.3 // indirect
184+
github.com/go-sql-driver/mysql v1.9.2 // indirect
185+
github.com/gobwas/glob v0.2.4-0.20181002190808-e7a84e9525fe // indirect
178186
github.com/gogo/protobuf v1.3.2 // indirect
179187
github.com/golang-jwt/jwt/v5 v5.3.0 // indirect
180188
github.com/golang/groupcache v0.0.0-20241129210726-2c02b8208cf8 // indirect
189+
github.com/golang/mock v1.6.0 // indirect
181190
github.com/golang/protobuf v1.5.4 // indirect
182191
github.com/google/btree v1.1.3 // indirect
183192
github.com/google/gnostic-models v0.7.0 // indirect
@@ -192,21 +201,32 @@ require (
192201
github.com/hashicorp/go-cleanhttp v0.5.2 // indirect
193202
github.com/hashicorp/go-retryablehttp v0.7.8 // indirect
194203
github.com/hashicorp/go-slug v0.16.8 // indirect
204+
github.com/hashicorp/go-uuid v1.0.3 // indirect
195205
github.com/hashicorp/go-version v1.8.0 // indirect
196206
github.com/hashicorp/jsonapi v1.4.3-0.20250220162346-81a76b606f3e // indirect
197207
github.com/huandu/xstrings v1.5.0 // indirect
198208
github.com/inconshreveable/mousetrap v1.1.0 // indirect
209+
github.com/jackc/pgio v1.0.0 // indirect
210+
github.com/jackc/pgtype v1.14.4 // indirect
199211
github.com/jbenet/go-context v0.0.0-20150711004518-d14ea06fba99 // indirect
212+
github.com/jcmturner/aescts/v2 v2.0.0 // indirect
213+
github.com/jcmturner/dnsutils/v2 v2.0.0 // indirect
214+
github.com/jcmturner/gofork v1.7.6 // indirect
215+
github.com/jcmturner/goidentity/v6 v6.0.1 // indirect
216+
github.com/jcmturner/gokrb5/v8 v8.4.4 // indirect
217+
github.com/jcmturner/rpc/v2 v2.0.3 // indirect
200218
github.com/jonboulle/clockwork v0.5.0 // indirect
201219
github.com/kballard/go-shellquote v0.0.0-20180428030007-95032a82bc51 // indirect
202220
github.com/kevinburke/ssh_config v1.2.0 // indirect
203221
github.com/klauspost/compress v1.18.3 // indirect
222+
github.com/klauspost/pgzip v1.2.6 // indirect
204223
github.com/kylelemons/godebug v1.1.0 // indirect
224+
github.com/lib/pq v1.10.9 // indirect
205225
github.com/liggitt/tabwriter v0.0.0-20181228230101-89fcab3d43de // indirect
206226
github.com/lucasb-eyer/go-colorful v1.2.0 // indirect
207-
github.com/mattn/go-colorable v0.1.14 // indirect
208227
github.com/mattn/go-isatty v0.0.20 // indirect
209228
github.com/mattn/go-runewidth v0.0.19 // indirect
229+
github.com/mattn/go-sqlite3 v1.14.28 // indirect
210230
github.com/mitchellh/copystructure v1.2.0 // indirect
211231
github.com/mitchellh/go-wordwrap v1.0.1 // indirect
212232
github.com/mitchellh/reflectwalk v1.0.2 // indirect
@@ -216,6 +236,7 @@ require (
216236
github.com/muesli/termenv v0.16.0 // indirect
217237
github.com/munnerz/goautoneg v0.0.0-20191010083416-a7dc8b61c822 // indirect
218238
github.com/mxk/go-flowrate v0.0.0-20140419014527-cca7078d478f // indirect
239+
github.com/ncruces/go-strftime v0.1.9 // indirect
219240
github.com/opencontainers/go-digest v1.0.0 // indirect
220241
github.com/opencontainers/image-spec v1.1.1 // indirect
221242
github.com/pelletier/go-toml/v2 v2.2.4 // indirect
@@ -228,16 +249,22 @@ require (
228249
github.com/prometheus/procfs v0.17.0 // indirect
229250
github.com/r3labs/diff/v3 v3.0.2 // indirect
230251
github.com/redis/go-redis/v9 v9.8.0 // indirect
252+
github.com/remyoudompheng/bigfft v0.0.0-20230129092748-24d4a6f8daec // indirect
231253
github.com/rivo/uniseg v0.4.7 // indirect
232254
github.com/robfig/cron/v3 v3.0.2-0.20210106135023-bc59245fe10e // indirect
233255
github.com/russross/blackfriday/v2 v2.1.0 // indirect
256+
github.com/segmentio/fasthash v1.0.3 // indirect
234257
github.com/sergi/go-diff v1.3.2-0.20230802210424-5b0b94c5c0d3 // indirect
258+
github.com/sethvargo/go-limiter v1.0.0 // indirect
235259
github.com/shopspring/decimal v1.4.0 // indirect
236260
github.com/sirupsen/logrus v1.9.4 // indirect
237261
github.com/skeema/knownhosts v1.3.1 // indirect
238-
github.com/spf13/cast v1.7.1 // indirect
262+
github.com/spf13/cast v1.9.2 // indirect
239263
github.com/spf13/pflag v1.0.10 // indirect
240264
github.com/testcontainers/testcontainers-go/modules/compose v0.41.0 // indirect
265+
github.com/upper/db/v4 v4.10.0 // indirect
266+
github.com/valyala/bytebufferpool v1.0.0 // indirect
267+
github.com/valyala/fasttemplate v1.2.2 // indirect
241268
github.com/vmihailenco/go-tinylfu v0.2.2 // indirect
242269
github.com/vmihailenco/msgpack/v5 v5.4.1 // indirect
243270
github.com/vmihailenco/tagparser/v2 v2.0.0 // indirect
@@ -246,16 +273,18 @@ require (
246273
github.com/xlab/treeprint v1.2.0 // indirect
247274
github.com/xo/terminfo v0.0.0-20220910002029-abceb7e1c41e // indirect
248275
go.opentelemetry.io/contrib/instrumentation/google.golang.org/grpc/otelgrpc v0.63.0 // indirect
276+
go.opentelemetry.io/otel/exporters/otlp/otlpmetric/otlpmetricgrpc v1.38.0 // indirect
277+
go.opentelemetry.io/otel/exporters/prometheus v0.58.0 // indirect
249278
go.yaml.in/yaml/v2 v2.4.3 // indirect
250279
go.yaml.in/yaml/v3 v3.0.4 // indirect
251-
golang.org/x/exp v0.0.0-20250911091902-df9299821621 // indirect
280+
golang.org/x/exp v0.0.0-20260218203240-3dfff04db8fa // indirect
252281
golang.org/x/net v0.50.0 // indirect
253282
golang.org/x/oauth2 v0.35.0 // indirect
254283
golang.org/x/sys v0.41.0 // indirect
255284
golang.org/x/term v0.40.0 // indirect
256285
golang.org/x/text v0.34.0 // indirect
257286
golang.org/x/time v0.14.0 // indirect
258-
google.golang.org/genproto v0.0.0-20241118233622-e639e219e697 // indirect
287+
google.golang.org/genproto v0.0.0-20250603155806-513f23925822 // indirect
259288
google.golang.org/protobuf v1.36.11 // indirect
260289
gopkg.in/evanphx/json-patch.v4 v4.12.0 // indirect
261290
gopkg.in/inf.v0 v0.9.1 // indirect
@@ -275,13 +304,18 @@ require (
275304
k8s.io/kube-openapi v0.0.0-20250710124328-f3f2b991d03b // indirect
276305
k8s.io/kubectl v0.34.0 // indirect
277306
k8s.io/kubernetes v1.34.2 // indirect
278-
k8s.io/utils v0.0.0-20250604170112-4c0f3b243397 // indirect
307+
k8s.io/utils v0.0.0-20260210185600-b8788abfbbc2 // indirect
308+
modernc.org/libc v1.65.8 // indirect
309+
modernc.org/mathutil v1.7.1 // indirect
310+
modernc.org/memory v1.11.0 // indirect
311+
modernc.org/sqlite v1.37.1 // indirect
279312
oras.land/oras-go/v2 v2.6.0 // indirect
280-
sigs.k8s.io/json v0.0.0-20241014173422-cfa47c3a1cc8 // indirect
313+
sigs.k8s.io/json v0.0.0-20250730193827-2d320260d730 // indirect
281314
sigs.k8s.io/kustomize/api v0.20.1 // indirect
282315
sigs.k8s.io/kustomize/kyaml v0.20.1 // indirect
283316
sigs.k8s.io/randfill v1.0.0 // indirect
284317
sigs.k8s.io/structured-merge-diff/v6 v6.3.1-0.20251003215857-446d8398e19c // indirect
318+
zombiezen.com/go/sqlite v1.4.2 // indirect
285319
)
286320

287321
tool github.com/oapi-codegen/oapi-codegen/v2/cmd/oapi-codegen

0 commit comments

Comments
 (0)