Skip to content
Merged
Show file tree
Hide file tree
Changes from 65 commits
Commits
Show all changes
66 commits
Select commit Hold shift + click to select a range
b2d5b8b
Shutdown/Cancel interface
maxdml Aug 20, 2025
3607d0f
should not need this
maxdml Aug 20, 2025
ed2f64c
comment
maxdml Aug 20, 2025
db5f224
deactivate just stops the wf scheduler + rebalance shutdown/cancel re…
maxdml Aug 20, 2025
5fde81e
comments
maxdml Aug 20, 2025
f450782
no cancel for now, just shutdown
maxdml Aug 21, 2025
3740223
shutdown systemdb last
maxdml Aug 21, 2025
84c216d
garbage collection, global timeout, set max/min conns and timeouts on…
maxdml Aug 21, 2025
c34ee72
nit
maxdml Aug 21, 2025
acbf5d9
more precise test
maxdml Aug 21, 2025
55ddd77
better test
maxdml Aug 21, 2025
0ed485b
one more test
maxdml Aug 21, 2025
9c993f6
Merge remote-tracking branch 'origin/main' into conductor
maxdml Aug 21, 2025
d0ee95f
basic conductor implementation
maxdml Aug 21, 2025
30cdd2d
list workflows
maxdml Aug 21, 2025
035f710
list queued workflows
maxdml Aug 21, 2025
3661ad4
list steps
maxdml Aug 21, 2025
6673424
get workflow
maxdml Aug 22, 2025
feb7cc8
fork workflow
maxdml Aug 22, 2025
488b27f
fix time
maxdml Aug 22, 2025
6e198bc
cancel wf
maxdml Aug 22, 2025
f3a36d9
recovery
maxdml Aug 22, 2025
8d38d5e
simpler
maxdml Aug 22, 2025
c249fab
handleExistPendingWorkflowsRequest
maxdml Aug 22, 2025
567211b
protect connection close with sync.Once
maxdml Aug 22, 2025
1f3b531
GC / resume
maxdml Aug 22, 2025
3c2e829
place logger correctly + fields export
maxdml Aug 22, 2025
4fdb5a8
should close no matter what
maxdml Aug 22, 2025
7a62a6c
simplify connection management
maxdml Aug 22, 2025
8515031
simplify
maxdml Aug 22, 2025
25cfc49
nit
maxdml Aug 22, 2025
66bdae0
cleanup
maxdml Aug 22, 2025
7852609
handle overflow + close errors
maxdml Aug 22, 2025
a65a5c1
have a cancel method for the ping go routine so we always have one, p…
maxdml Aug 22, 2025
77bb694
generate executor ID in conductor mode if default is set + return an …
maxdml Aug 23, 2025
2f5ce65
nit + no leak
maxdml Aug 23, 2025
0b635b9
handle errors when setting write dl
maxdml Aug 23, 2025
e326a2f
prevent integer overflow
maxdml Aug 23, 2025
4c5c2be
call pingcancel on shutdown. Shouldn't need it?
maxdml Aug 23, 2025
71dba84
more api key leaks
maxdml Aug 25, 2025
fbb0484
logs cleanup
maxdml Aug 25, 2025
ef41cca
more logs
maxdml Aug 25, 2025
646769d
more logs
maxdml Aug 25, 2025
02bb44d
logger service key
maxdml Aug 25, 2025
63032cc
debug
maxdml Aug 25, 2025
e45cd37
do not nil-ify pointers
maxdml Aug 25, 2025
5b3e5dd
more logs
maxdml Aug 25, 2025
686ea4d
micro
maxdml Aug 25, 2025
9313d13
close the connection at shutdown + fix race condition
maxdml Aug 25, 2025
d4e65bf
one more bug
maxdml Aug 25, 2025
ee3c212
nits
maxdml Aug 25, 2025
8e5a2e4
bug
maxdml Aug 25, 2025
e9848a5
cleanup
maxdml Aug 25, 2025
79ef8ba
cleanup
maxdml Aug 25, 2025
c7ee7cc
fix a bug in recording dequeued workflows as steps of the parent
maxdml Aug 26, 2025
c897e48
more thorough startStep check
maxdml Aug 26, 2025
5eb8343
add jitter to reconnect logic
maxdml Aug 26, 2025
4724ee5
fix bug in gc
maxdml Aug 26, 2025
a040d5f
fix
maxdml Aug 26, 2025
f8e1525
fix
maxdml Aug 26, 2025
8ae827f
fix race conditions
maxdml Aug 26, 2025
5632d47
add conductor connection management tests
maxdml Aug 26, 2025
cbf578d
nit in tests
maxdml Aug 26, 2025
ef07ad4
serialize conductor test server
maxdml Aug 27, 2025
329fac7
cleanup
maxdml Aug 27, 2025
6b5f579
always generate new ID for executor if conductor key is set
maxdml Aug 27, 2025
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 0 additions & 3 deletions dbos/admin_server_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -34,9 +34,6 @@ func TestAdminServer(t *testing.T) {
}
}()

// Give time for any startup processes
time.Sleep(100 * time.Millisecond)

// Verify admin server is not running
client := &http.Client{Timeout: 1 * time.Second}
_, err = client.Get(fmt.Sprintf("http://localhost:3001/%s", strings.TrimPrefix(_HEALTHCHECK_PATTERN, "GET /")))
Expand Down
Loading
Loading