Skip to content

Instantly share code, notes, and snippets.

@joni1993

joni1993/gist:6bc0abbd5d8cdf35104937cc34d32ab7 Secret

Created February 8, 2024 07:48
Show Gist options
  • Save joni1993/6bc0abbd5d8cdf35104937cc34d32ab7 to your computer and use it in GitHub Desktop.
Save joni1993/6bc0abbd5d8cdf35104937cc34d32ab7 to your computer and use it in GitHub Desktop.
Download ZIP
Extensive Log
Raw
gistfile1.txt
[2024-02-08 07:34:08] local.INFO: select * from `jobs` where `queue` = ? and ((`reserved_at` is null and `available_at` <= ?) or (`reserved_at` <= ?)) order by `id` asc limit 1 FOR UPDATE SKIP LOCKED ["default",1707377648,1707377558]
[2024-02-08 07:34:08] local.INFO: update `jobs` set `reserved_at` = ?, `attempts` = ? where `id` = ? [1707377648,26,95242]
[2024-02-08 07:34:08] local.INFO: select * from `workflows` where `workflows`.`id` = ? limit 1 ["MYWORKFLOW_ID"]
[2024-02-08 07:34:08] local.DEBUG: Activity started:MYWORKFLOW_ID - 162 - App\Workflows\ACTIVITY_B - c6e15949-8df3-4d40-bbb4-a30e789b2af3
[2024-02-08 07:34:08] local.INFO: select exists(select * from `workflow_logs` where `workflow_logs`.`stored_workflow_id` = ? and `workflow_logs`.`stored_workflow_id` is not null and `index` = ?) as `exists` ["MYWORKFLOW_ID",162]
[2024-02-08 07:34:08] local.INFO: select * from `workflows` where `id` = ? limit 1 ["MYWORKFLOW_ID"]
[2024-02-08 07:34:08] local.INFO: select * from `workflows` where `id` = ? limit 1 ["MYWORKFLOW_ID"]
[2024-02-08 07:34:08] local.INFO: select * from `jobs` where `id` = ? limit 1 for update [95242]
[2024-02-08 07:34:08] local.INFO: delete from `jobs` where `id` = ? [95242]
[2024-02-08 07:34:08] local.INFO: (-----INSERT JOBS query for ACTIVITY_B----)
[2024-02-08 07:34:08] local.INFO: select * from `jobs` where `queue` = ? and ((`reserved_at` is null and `available_at` <= ?) or (`reserved_at` <= ?)) order by `id` asc limit 1 FOR UPDATE SKIP LOCKED ["default",1707377648,1707377558]
[2024-02-08 07:34:08] local.INFO: update `jobs` set `reserved_at` = ?, `attempts` = ? where `id` = ? [1707377648,24,95243]
[2024-02-08 07:34:08] local.INFO: select * from `workflows` where `workflows`.`id` = ? limit 1 ["MYWORKFLOW_ID"]
[2024-02-08 07:34:08] local.DEBUG: Activity started:MYWORKFLOW_ID - 163 - App\Workflows\ACTIVITY_A - cc976449-cc06-4d2c-be86-a2664486efc6
[2024-02-08 07:34:08] local.INFO: select exists(select * from `workflow_logs` where `workflow_logs`.`stored_workflow_id` = ? and `workflow_logs`.`stored_workflow_id` is not null and `index` = ?) as `exists` ["MYWORKFLOW_ID",163]
[2024-02-08 07:34:08] local.INFO: select * from `workflows` where `id` = ? limit 1 ["MYWORKFLOW_ID"]
[2024-02-08 07:34:08] local.INFO: select * from `workflows` where `id` = ? limit 1 ["MYWORKFLOW_ID"]
[2024-02-08 07:34:08] local.INFO: select * from `jobs` where `id` = ? limit 1 for update [95243]
[2024-02-08 07:34:08] local.INFO: delete from `jobs` where `id` = ? [95243]
[2024-02-08 07:34:08] local.INFO: (-----INSERT JOBS query for ACTIVITY_A----)
[2024-02-08 07:34:08] local.INFO: select * from `jobs` where `queue` = ? and ((`reserved_at` is null and `available_at` <= ?) or (`reserved_at` <= ?)) order by `id` asc limit 1 FOR UPDATE SKIP LOCKED ["default",1707377648,1707377558]
[2024-02-08 07:34:08] local.INFO: update `jobs` set `reserved_at` = ?, `attempts` = ? where `id` = ? [1707377648,23,95244]
[2024-02-08 07:34:08] local.INFO: select * from `workflows` where `workflows`.`id` = ? limit 1 ["MYWORKFLOW_ID"]
[2024-02-08 07:34:08] local.DEBUG: Activity started:MYWORKFLOW_ID - 165 - App\Workflows\ACTIVITY_B - 54cc9c73-5279-4125-8b26-e9350ffe9a2d
[2024-02-08 07:34:08] local.INFO: select exists(select * from `workflow_logs` where `workflow_logs`.`stored_workflow_id` = ? and `workflow_logs`.`stored_workflow_id` is not null and `index` = ?) as `exists` ["MYWORKFLOW_ID",165]
[2024-02-08 07:34:08] local.INFO: select * from `workflows` where `id` = ? limit 1 ["MYWORKFLOW_ID"]
[2024-02-08 07:34:09] local.INFO: select * from `workflows` where `id` = ? limit 1 ["MYWORKFLOW_ID"]
[2024-02-08 07:34:09] local.INFO: select * from `jobs` where `id` = ? limit 1 for update [95244]
[2024-02-08 07:34:09] local.INFO: delete from `jobs` where `id` = ? [95244]
[2024-02-08 07:34:08] local.INFO: (-----INSERT JOBS query for ACTIVITY_B----)
(------------------- REPEATS A FEW TIMES -------------------)
[2024-02-08 07:34:10] local.INFO: select * from `jobs` where `queue` = ? and ((`reserved_at` is null and `available_at` <= ?) or (`reserved_at` <= ?)) order by
`id` asc limit 1 FOR UPDATE SKIP LOCKED ["default",1707377650,1707377560]
[2024-02-08 07:34:10] local.INFO: update `jobs` set `reserved_at` = ?, `attempts` = ? where `id` = ? [1707377650,1,95257]
[2024-02-08 07:34:10] local.INFO: select * from `workflows` where `workflows`.`id` = ? limit 1 ["MYWORKFLOW_ID"]
[2024-02-08 07:34:10] local.INFO: select `workflows`.*, `workflow_relationships`.`child_workflow_id` as `pivot_child_workflow_id`, `workflow_relationships`.`pa
rent_workflow_id` as `pivot_parent_workflow_id`, `workflow_relationships`.`parent_index` as `pivot_parent_index`, `workflow_relationships`.`parent_now` as `piv
ot_parent_now` from `workflows` inner join `workflow_relationships` on `workflows`.`id` = `workflow_relationships`.`parent_workflow_id` where `workflow_relatio
nships`.`child_workflow_id` = ? limit 1 ["MYWORKFLOW_ID"]
[2024-02-08 07:34:10] local.INFO: update `workflows` set `status` = ?, `workflows`.`updated_at` = ? where `id` = ? ["running","2024-02-08 07:34:10.112756","AT0
02000202312281708315131014336341"]
[2024-02-08 07:34:10] local.INFO: select `workflows`.*, `workflow_relationships`.`child_workflow_id` as `pivot_child_workflow_id`, `workflow_relationships`.`pa
rent_workflow_id` as `pivot_parent_workflow_id`, `workflow_relationships`.`parent_index` as `pivot_parent_index`, `workflow_relationships`.`parent_now` as `piv
ot_parent_now` from `workflows` inner join `workflow_relationships` on `workflows`.`id` = `workflow_relationships`.`parent_workflow_id` where `workflow_relatio
nships`.`child_workflow_id` = ? limit 1 ["MYWORKFLOW_ID"]
[2024-02-08 07:34:10] local.INFO: select * from `workflow_logs` where `workflow_logs`.`stored_workflow_id` = ? and `workflow_logs`.`stored_workflow_id` is not
null and `index` = ? limit 1 ["MYWORKFLOW_ID",0]
[2024-02-08 07:34:10] local.INFO: select * from `workflow_signals` where `workflow_signals`.`stored_workflow_id` = ? and `workflow_signals`.`stored_workflow_id
` is not null and `created_at` <= ? order by `workflow_signals`.`id` asc limit 1000 offset 0 ["MYWORKFLOW_ID","2024-02-08 06:25:29.923626"]
(------------------- LOGS OF WORKFLOW REPLAY RUN -------------------)
(------------------- many SELECTs of workflow_logs + Workflow log messages -------------------)
(------------------- ending with: -------------------)
[2024-02-08 07:34:20] local.INFO: select * from `workflow_logs` where `workflow_logs`.`stored_workflow_id` = ? and `workflow_logs`.`stored_workflow_id` is not
null and `index` = ? limit 1 ["MYWORKFLOW_ID",181]
[2024-02-08 07:34:20] local.INFO: select * from `workflow_logs` where `workflow_logs`.`stored_workflow_id` = ? and `workflow_logs`.`stored_workflow_id` is not
null and `index` = ? limit 1 ["MYWORKFLOW_ID",182]
[2024-02-08 07:34:20] local.INFO: select * from `workflow_signals` where `workflow_signals`.`stored_workflow_id` = ? and `workflow_signals`.`stored_workflow_id
` is not null and `created_at` > ? and `created_at` <= ? order by `workflow_signals`.`id` asc limit 1000 offset 0 ["MYWORKFLOW_ID","2024-
02-08 07:21:19.759888","2024-02-08 07:21:33.783065"]
[2024-02-08 07:34:20] local.DEBUG: yielding E3 - finish: ACOLLECTION_KEY
[2024-02-08 07:34:20] local.INFO: select * from `workflow_logs` where `workflow_logs`.`stored_workflow_id` = ? and `workflow_logs`.`stored_workflow_id` is not
null and `index` = ? limit 1 ["MYWORKFLOW_ID",182]
[2024-02-08 07:34:20] local.DEBUG: [REDACTED LOG ENTRY]
[2024-02-08 07:34:20] local.DEBUG: (inside awaits) if true
[2024-02-08 07:34:20] local.DEBUG: (inside awaits) index: 183
[2024-02-08 07:34:20] local.DEBUG: (inside awaits) Return: {}
[2024-02-08 07:34:20] local.INFO: select * from `workflow_logs` where `workflow_logs`.`stored_workflow_id` = ? and `workflow_logs`.`stored_workflow_id` is not
null and `index` = ? limit 1 ["MYWORKFLOW_ID",183]
[2024-02-08 07:34:20] local.INFO: select * from `workflow_signals` where `workflow_signals`.`stored_workflow_id` = ? and `workflow_signals`.`stored_workflow_id
` is not null and `created_at` > ? and `created_at` <= ? order by `workflow_signals`.`id` asc limit 1000 offset 0 ["MYWORKFLOW_ID","2024-
02-08 07:21:33.783065","2024-02-08 07:21:46.096649"]
[2024-02-08 07:34:20] local.DEBUG: yielding ACTIVITY_B: ACOLLECTION_KEY
[2024-02-08 07:34:20] local.INFO: select * from `workflow_logs` where `workflow_logs`.`stored_workflow_id` = ? and `workflow_logs`.`stored_workflow_id` is not null and `index` = ? limit 1 ["MYWORKFLOW_ID",183]
[2024-02-08 07:34:20] local.INFO: select * from `workflow_logs` where `workflow_logs`.`stored_workflow_id` = ? and `workflow_logs`.`stored_workflow_id` is not null and `index` = ? limit 1 ["MYWORKFLOW_ID",184]
[2024-02-08 07:34:20] local.INFO: select * from `workflow_signals` where `workflow_signals`.`stored_workflow_id` = ? and `workflow_signals`.`stored_workflow_id` is not null and `created_at` > ? order by `workflow_signals`.`id` asc limit 1000 offset 0 ["MYWORKFLOW_ID","2024-02-08 07:21:46.096649"]
[2024-02-08 07:34:20] local.DEBUG: yielding ACTIVITY_B finish: AT002000202401022(inside awaits)152159716568268034
[2024-02-08 07:34:20] local.DEBUG: (Inner loop end) Responses to handle: 0
[2024-02-08 07:34:20] local.DEBUG: end loop:MYWORKFLOW_ID
[2024-02-08 07:34:20] local.DEBUG: end foreach loop :MYWORKFLOW_ID
[2024-02-08 07:34:20] local.DEBUG: IsNotEmpty ('MYWORKFLOW_ID'):Nein
[2024-02-08 07:34:20] local.DEBUG: finished ('MYWORKFLOW_ID'):Nein
[2024-02-08 07:34:20] local.INFO: select * from `workflow_logs` where `workflow_logs`.`stored_workflow_id` = ? and `workflow_logs`.`stored_workflow_id` is not null and `index` = ? limit 1 ["MYWORKFLOW_ID",184]
[2024-02-08 07:34:20] local.DEBUG: Log:null
[2024-02-08 07:34:20] local.DEBUG: (inside awaits) result: false
[2024-02-08 07:34:20] local.DEBUG: (inside awaits) index1: 184
[2024-02-08 07:34:20] local.DEBUG: (inside awaits) index2: 185
(------------------- THE STRANGE STUFF: -------------------)
[2024-02-08 07:34:20] local.INFO: select * from `workflow_logs` where `workflow_logs`.`stored_workflow_id` = ? and `workflow_logs`.`stored_workflow_id` is not null and `index` = ? limit 1 ["MYWORKFLOW_ID",185]
[2024-02-08 07:34:21] local.INFO: update `workflows` set `status` = ?, `workflows`.`updated_at` = ? where `id` = ? ["waiting","2024-02-08 07:34:20.995890","MYWORKFLOW_ID"]
[2024-02-08 07:34:21] local.INFO: select * from `jobs` where `id` = ? limit 1 for update [95257]
[2024-02-08 07:34:21] local.INFO: delete from `jobs` where `id` = ? [95257]
[2024-02-08 07:34:21] local.INFO: select * from `jobs` where `queue` = ? and ((`reserved_at` is null and `available_at` <= ?) or (`reserved_at` <= ?)) order by `id` asc limit 1 FOR UPDATE SKIP LOCKED ["default",1707377661,1707377571]
[2024-02-08 07:34:21] local.INFO: update `jobs` set `reserved_at` = ?, `attempts` = ? where `id` = ? [1707377661,61,95258]
[2024-02-08 07:34:21] local.INFO: select * from `workflows` where `workflows`.`id` = ? limit 1 ["MYWORKFLOW_ID"]
[2024-02-08 07:34:21] local.DEBUG: Activity started:MYWORKFLOW_ID - 109 - App\Workflows\ACTIVITY_A - c8edce86-74d1-4b0d-99af-1fd2a853882b
[2024-02-08 07:34:21] local.INFO: select exists(select * from `workflow_logs` where `workflow_logs`.`stored_workflow_id` = ? and `workflow_logs`.`stored_workflow_id` is not null and `index` = ?) as `exists` ["MYWORKFLOW_ID",109]
[2024-02-08 07:34:21] local.INFO: select * from `workflows` where `id` = ? limit 1 ["MYWORKFLOW_ID"]
[2024-02-08 07:34:21] local.INFO: update `workflows` set `status` = ?, `workflows`.`updated_at` = ? where `id` = ? ["pending","2024-02-08 07:34:21.082025","MYWORKFLOW_ID"]
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment