mirror of
https://github.com/hatchet-dev/hatchet.git
synced 2026-04-24 02:59:55 -05:00
feat: dag-style execution (#108)
* feat: dag-style execution * docs: update to reflect new context * ensure no cycles * remove example cycle * linting * lint and small fixes * update deferred rollback * last rollback handling * unset max issues * fix requeue edge case
This commit is contained in:
abelanger5
@@ -228,9 +228,10 @@ type ReplayEventRequest struct {
|
||||
// Step defines model for Step.
|
||||
type Step struct {
|
||||
Action string `json:"action"`
|
||||
Children *[]string `json:"children,omitempty"`
|
||||
JobId string `json:"jobId"`
|
||||
Metadata APIResourceMeta `json:"metadata"`
|
||||
NextId string `json:"nextId"`
|
||||
Parents *[]string `json:"parents,omitempty"`
|
||||
|
||||
// ReadableId The readable id of the step.
|
||||
ReadableId string `json:"readableId"`
|
||||
@@ -245,15 +246,15 @@ type StepRun struct {
|
||||
CancelledAt *time.Time `json:"cancelledAt,omitempty"`
|
||||
CancelledError *string `json:"cancelledError,omitempty"`
|
||||
CancelledReason *string `json:"cancelledReason,omitempty"`
|
||||
Children *[]string `json:"children,omitempty"`
|
||||
Error *string `json:"error,omitempty"`
|
||||
FinishedAt *time.Time `json:"finishedAt,omitempty"`
|
||||
Input *string `json:"input,omitempty"`
|
||||
JobRun *JobRun `json:"jobRun,omitempty"`
|
||||
JobRunId string `json:"jobRunId"`
|
||||
Metadata APIResourceMeta `json:"metadata"`
|
||||
NextId *string `json:"nextId,omitempty"`
|
||||
Output *string `json:"output,omitempty"`
|
||||
PrevId *string `json:"prevId,omitempty"`
|
||||
Parents *[]string `json:"parents,omitempty"`
|
||||
RequeueAfter *time.Time `json:"requeueAfter,omitempty"`
|
||||
Result *map[string]interface{} `json:"result,omitempty"`
|
||||
StartedAt *time.Time `json:"startedAt,omitempty"`
|
||||
@@ -2262,67 +2263,67 @@ func (sh *strictHandler) WorkflowVersionGetDefinition(ctx echo.Context, workflow
|
||||
// Base64 encoded, gzipped, json marshaled Swagger object
|
||||
var swaggerSpec = []string{
|
||||
|
||||
"H4sIAAAAAAAC/+xcW3PbOLL+Kyie83BOlS6+TSarNyf2ZDxre1KyPandlCsFkS0JMUUwAGhHm/J/38KN",
|
||||
"BC2QIiXZI8/oybSIS6P76wu6Af4IQjpLaQKJ4MHgR8DDKcywejz+eHbKGGXyOWU0BSYIqDchjUD+jYCH",
|
||||
"jKSC0CQYBBiFGRd0hn7FIpyCQCB7I9W4E8B3PEtjCAb7R3t7nWBM2QyLYBBkJBFvjoJOIOYpBIOAJAIm",
|
||||
"wILHTnn4xdmc/9GYMiSmhOs53emC46LhPRiaZsA5nkAxKxeMJBM1KQ35l5gkd74p5e9IUCSmgCIaZjNI",
|
||||
"BPYQ0EFkjIhA8J1wwUvkTIiYZqNeSGf9qeZTN4J7++yjaEwgjhapkTSoV0hMsXAmR4QjzDkNCRYQoQci",
|
||||
"pooenKYxCfEoLokjSPDMw4jHTsDgW0YYRMHgc2nq27wxHX2FUEgaLVb4Ilgg/50ImKmH/2UwDgbB//QL",
|
||||
"7PUN8Po56h7zaTBjeL5Akhm3gpohcJqxEC5AYA+AGUjeHAs/WwWZgcNVZsZCD5gj07XEwoO9g4Pu/kF3",
|
||||
"//D6YG+w92Zw9Lb39u3bfwcOziMsoCsH9omYVMiXRIiOy0R0EEnQzc3ZCTJDu4SMRgf7R2/3fu4eHL2B",
|
||||
"7tEh/qmLD36Kukf7P7/Zj/bD8fgf4BKVZUSuZIa/n0MyEdNgcPimE8xI4v67QG2WRqtyL8ZcINN/kyx8",
|
||||
"gg21qkLILsk+vLxXLa8hwYkYwrcMuFjEjNKThQVfTwHJN1pOgIQapLdAYSf43qU4JV1pDieQdOG7YLgr",
|
||||
"8EQNfo9jIikMBsU65KJ4nE38k8o3m5+0Y+zQpVzs41O2GlOhiPLx8fQeEg/n7mDuX8MdzI3hBASyb8+n",
|
||||
"HDMQOMJajZdYjpLWSwOiGLOsoxZ80f4s8pN7dlJm+FMra2xw5UIeKLsbx/RhmCVX2WyG2XwZZYqhnxa7",
|
||||
"PRVMzqKOYrazkFsrlhPsM4SWr4uLlW/KwkH/99vV75doNBfA/7+33GXIofPp/7keBuwY58SnmimekATb",
|
||||
"OKGOoR/zlkPgKU04yNEZfWjuoPLlLDooS+i2UFlD4u8sAvZufkIYhJYkSLKZlBzmYaCjL0fLn8jC9P/F",
|
||||
"xia2b2F0K7teAWbhVHbyv//kVZMyL8eYxFChpkk2GwGTqqpbIZYlvOc6kuqQM4UkkrQsGdg0azMyy5Kk",
|
||||
"wcimWZuReRaGANFyduQNm48u8fIbHXkMR11sruyHE50bq/mVjjZt4K1TXhiTC0iba8uVgHRRWcr+YGEK",
|
||||
"GYnQTPiXb14uW/o9ME5o4p2h2sbnZLkDdHL3rJbu88+/0dEwSzzhME5CiGMb0jWLWfNO+SaxuskQMNdA",
|
||||
"8exuEsKn7ab+qhFZJ1EJWt2yQnprgI4Bz2LhjFpwmAvMRLvFcIFFxhusR9pD3dbge5gl7SAuhd8e5eEd",
|
||||
"sHoVaLNcJwhaRrLjCJ70XF1fyoNYgORSqNaaq1xM1tV9PL08Obv8EHSC4c3lpX66unn//vT05PQk6AS/",
|
||||
"HJ+dq4f3x5fvT8/ls88nepy9nMTujH4EYcYYJOJLiicQDA46QQLf7X+HnSDJZuofHgz296QLK6t2qbNv",
|
||||
"u2ZaoFQnRPKJDxo5H4cW3+Dy9cLIh81GLtbl3WVSgWPXJcumKpKMCRd691PknPaa+DqP7IeQxniuwpLK",
|
||||
"jaGKWs+isiq+9J68PlViKZThuPJ1C4vAeRTos7abt6ESGBWjMsARHsVQtQ2z7/PsCCBpDb3+dWMOvGKG",
|
||||
"apvjrKJkgKzBMQzPOeGzPNZmb5XDhsreq7hykqSZqIJdAx9hQpq8/YsilWaiivqUwX0lvr9lkMHxWABr",
|
||||
"zqg/I+gw+CtHHU1jadm2SvEaaGXbmKIiRmkUFOTQyamuDQjKbPFGBObpy/HV1dmHy4vTy+ugE+h/VEiw",
|
||||
"VsRwnWe1ylZhA/uo1ZKbaycqa8S0LOeomXEBMg7YKEsY1eHX8syhnnwo26+Qc8y4Jryu9Q0Hpnt8zEYx",
|
||||
"CesYpsYz5C9j2NCs0QL490+Xp0OJ1JOLs8ugE1ycXrw7HXpBeMN9/IYZJrEfB+oVwlHEgHMLCElsKRGh",
|
||||
"B/DMp178AYyMiS/T8WkKYgosHxRNMUf3prn8lbAyBQ4IR5TGgJMNpSI8qRDCZRRZUiW78MZ6YBlT5oNP",
|
||||
"wFIy53RCkuqI9XmktEK5QQ8kl51izh8oq4j57Nt69q1AQD7tQrHDrjFvUcXrIUwIF/LvK2J3M4NfgdIt",
|
||||
"lJZxE42F5lpBPiUp34KcfcmVPd3TSW5NaFfLLRjKcRUTFlzDC9rk5zB5ejKf2D6pKK9q68r9hJiXujSn",
|
||||
"40QU4gSlwOT6JD25bJZsqjtBjLn4FTATI8DiuGbjWJpO1bw5JAJhNLW9e5s9QPDsoZ9eS8+/MwkhEVdO",
|
||||
"QtK3Z5dt1C5aFR+K8zLFwOulMZdEkNWA2gLFN8j2VutsEnQzJRib/uxVpNUrxCff+IZotDqTivcpU/sk",
|
||||
"8IsAvZJD1jd5tB5PVueQXeM19podU+Nphyc53h+6Y34aYhMKI8f1q8waonlxbVMa5WNJ5Zq9ebhnyoXh",
|
||||
"KCJyiTj+6EwnWAYeAnXyovnyi4zZU5ytIcBnS0G5hwHyNFR9/oiRyQQYRO/mLQa/dno5tSajQS0VzjPC",
|
||||
"+hWrP5xKr+FdebG39ejdEj/n2PJWyvds9bcKEHjOjNLkI2ZQCTzZ4CqcQpTF/jMJYI/HNTq4Y4o2m05n",
|
||||
"p9VLqIZj3qkOY9J7eY6Kx9pCrh+erO2//VtGTWHtwjQs3jMJ/bEfGf4igGLbF1LB7GUTmrLjuKLk+MWc",
|
||||
"q9z0tNy/wvZq/oRvHo+j1rHywDl/NuvLtO31s68wx19MVNaezY5PKXPZxt/rRNVrrJuy6ElBiiTi8MBb",
|
||||
"nBcOVFpIjDvhrF+VzctGBuHB2Ro1Dfhsn5YG0NJsuVQa6Ha5sE9ABoTCK3aGH8qvPdtn/ID+dXxxjqK8",
|
||||
"YXt7V56nAdH+uxMvhLC/AUpkEAxhxoiYy7hhpvk7AsyAHWdimt/HUkUK9XOxwKkQqswaUnpHwDYnkkP6",
|
||||
"J7uRGwQLd4twStQB5ke16RhTP5PtNa7jj2eyKxEqVVX+NZdSsN/b6+0pIaeQ4JQEg+Cwt9/bU9GDmKql",
|
||||
"9XFK+vf7fW32+z/U38e+RdMEPCm1DyD0dSt7Hh0nxTlxiUsVkkpBFefcP6jFppjhGQhlpT57s5/qVLs6",
|
||||
"baP4JuksuKajNVfWegOm8VJC8SpHdh5vVU1fBdKKOQd7ezpgSoQJE82FLUlx/6s5jlHMvjSIVCf+lYzL",
|
||||
"S7/KwhA4H2dxPEcMBCNwr2tkhiNKHo+d4GiDFBUXxDwUHaMZjiU3IUKUoRGOEDPFFEXG4cuQ8QtlIxJF",
|
||||
"kGjVtGfPFQQdztg00Gdz3+W2E3zv2ltO6ndTArYR/60czmJfv9MxFuUewOvLSBxhlMADyocqQ11n/HVT",
|
||||
"g1Hg4h2N5htjle9SlIdp18V1GEHN7bgFrXl8RqzbSvoSoJuLCc4xhL84xNsgXMu6AJsFuOHtAsJ9iO7/",
|
||||
"0A+P/SKq91r0c8IFRziOtVLpWgB2zoZ4rLpKXjQw6QaJVTY9X+BzGfVOzQ0MQRG/I6ml7FsGbF6QRsdj",
|
||||
"rtyWh5TqE6v108VkRgQazSumVK/XnfFYnbeVkdgdzLmcdUxiAax6WtmuNOu61668XODqlhFScztUjdXt",
|
||||
"cB9ZukOJsKX0mKtMHhI+qfuvFKlAsJoX1L1G1Wrq0gWsCh7oyaP8jlctDSdOs/Z0FL1fILJR1mCZwZew",
|
||||
"dMMavgtpCoMvOWjZ0jieaWL1+0q7G5p+bTIamH978/MVeIBnB7/lRVv8K2bvdMCnA8i4pE3qAVM3R6rD",
|
||||
"fH2zRIb51n/qjhUacKM+YKA7vRo12PymxHMfp2JPYjf3KiRhlm8vty1p7qg0cTtXVaGmWuQbdlYP+Vmy",
|
||||
"yqST9FK6WdlFLeinc4zob+6fHE60yzvZNOkO+E/STgaADuzNWbE1cC8Z3WVZwvs/3H8f67UhlxFiWbJc",
|
||||
"IUxFvWEmdiu37aUFV5HmcvAVa21+KmMltZUc2mnuoubmvCmrr6oy1WSNS5hqps+8kStTLZvp7s6dFYqx",
|
||||
"c2ibVwveSicaKkGfmYOQjTShOIjexJPtMtDbmoF2d3tyzgmIXLS9iont4bqXCiGaU+acGHh14cMahlLx",
|
||||
"ZWcsq2OINQxmxoHxvvnOS5155Mj9IIy5SFy2iDcc2AcQ781gz4grdcG4HZgUxduEof2XIeMmwZmYUkb+",
|
||||
"A5Ge+KeXmfgCxJRGKKHKs9IH+9VSc6pJuUj3gNLnW2mKyiB/AjeLcSV+D4xjOiFJdVr1nE44IgnC+XXD",
|
||||
"RfzqXKq6Iv1MZycWrmA/mgurf6auxHQygQiRZKciW6UiJY1QqGmhC+b7RTXKQDPRTBvkUFuCUUnKDqSv",
|
||||
"x45r9DSF7ay4dd+gUmw2VE6n/HvBtZGK/4b/MwPcP2mLUu3iandBcXMYEi58HFwOSWa+4VFXr9UteK0x",
|
||||
"fdYTmb6PjWxDYGGZt4vCX0WIYSG03Fyb6pOuEwFrUiHyGGJdsWpYCTLfzKgrt+jPW73a8ugKCZIt06et",
|
||||
"qYu2KIvajwQuAlxnjvNSaOMyaKPEcQvUmzxhfZnxlVdSVkwO7tDvzwuuWFdcrgN995MjTZTBXshrpBTm",
|
||||
"euEr0o365L5ZfA+djZUT5pmEBEQdBeIYC+Ai5xDhaAwinEJUVQEobhG+JtXOP32xWvr/vvhyxt9Y0+Ws",
|
||||
"Ry8z6yUVaEyzJKqrOxRQfGY7049KN6DbmBznSnRL6+Pcht7Zob+YHXJku55FcvC1M07baJxcAa1up56m",
|
||||
"mdxb+J9vpeJ5Ek/A7q29yFgcDILg8fbxvwEAAP//f0A071J1AAA=",
|
||||
"H4sIAAAAAAAC/+xcW3PbOLL+Kyie83BOlS6+TSarNyf2ZDxre1KyPandlCsFkS0JMUUoAGhHm9J/38KN",
|
||||
"BC2QInXxyDN6Mi0C6Ebj6wu6Af4IQjqZ0gQSwYPej4CHY5hg9Xj68eKcMcrk85TRKTBBQL0JaQTybwQ8",
|
||||
"ZGQqCE2CXoBRmHJBJ+hXLMIxCASyN1KNWwF8x5NpDEHv8OTgoBUMKZtgEfSClCTizUnQCsRsCkEvIImA",
|
||||
"EbBg3ioOv0jN+R8NKUNiTLim6ZILTvOGj2B4mgDneAQ5VS4YSUaKKA35l5gkDz6S8nckKBJjQBEN0wkk",
|
||||
"AnsYaCEyREQg+E644AV2RkSM00EnpJPuWMupHcGjffZxNCQQR4vcSB7UKyTGWDjEEeEIc05DggVE6ImI",
|
||||
"seIHT6cxCfEgLixHkOCJRxDzVsDgW0oYREHvc4H0fdaYDr5CKCSPFit8ESyQ/U4ETNTD/zIYBr3gf7o5",
|
||||
"9roGeN0MdfOMDGYMzxZYMuOWcNMHTlMWwhUI7AEwAymbU+EXqyATcKTKzFjoCXNkuhZEeHRwdNQ+PGof",
|
||||
"Ht8eHfQO3vRO3nbevn3778DBeYQFtOXAviUmJetLIkSHRSZaiCTo7u7iDJmhXUYGg6PDk7cHP7ePTt5A",
|
||||
"++QY/9TGRz9F7ZPDn98cRofhcPgPcJlKUyJnMsHfLyEZiXHQO37TCiYkcf9d4DadRqtKL8ZcINN/kyJ8",
|
||||
"hg01q3yRXZZ9eHmvWt5CghPRh28pcLGIGaUnCxO+HQOSb/Q6ARJqkM4Ch63ge5viKWlLcziCpA3fBcNt",
|
||||
"gUdq8EccE8lh0MvnISfF43TkJyrfbJ5oy9ihaznZ+XOxGlOhmPLJ8fwREo/kHmDmn8MDzIzhBASyb8en",
|
||||
"HBMQOMJajZdYjoLWSwOiBLOso174vP1F5Gf34qwo8OdW1tjg0ok8UfYwjOlTP01u0skEs9kyzpRAPy12",
|
||||
"e74wmYhaStjORO7tspxhnyG0cl2crHxTXBz0f7/d/H6NBjMB/P87y12GHDoj/8/1MGDHuCQ+1ZziEUmw",
|
||||
"jROqBPoxa9kHPqUJBzk6o0/1HVQ2nUUHZRndFS4rWPydRcDezc4Ig9CyBEk6kSuHeRjo6MvR8mdrYfr/",
|
||||
"YmMT2zc3uqVdbwCzcCw7+d9/8qpJUZZDTGIoUdMknQyASVXVrRBLE95xHUl5yDmFJJK8LBnYNGsyMkuT",
|
||||
"pMbIplmTkXkahgDRcnFkDeuPLvHyGx14DEdVbK7shxOdG6v5lQ42beCtU14YkwuY1teWGwHTRWUp+oMF",
|
||||
"EjISoanwT9+8XDb1R2Cc0MRLodzGZ2y5A7Qy96ym7vPPv9FBP0084TBOQohjG9LVi1mzTtkmsbxJHzDX",
|
||||
"QPHsbhLCx81If9WIrFpRCVrdsmT11gAdA57Gwhk1lzAXmIlmk+ECi5TXmI+0h7qtwXc/TZpBXC5+c5SH",
|
||||
"D8CqVaDJdJ0gaBnLjiN41nN1fSkOYgGSrUK51txky2Rd3cfz67OL6w9BK+jfXV/rp5u79+/Pz8/Oz4JW",
|
||||
"8MvpxaV6eH96/f78Uj77fKLH2Usidmf0IwhTxiARX6Z4BEHvqBUk8N3+d9wKknSi/uFB7/BAurCiahc6",
|
||||
"+7ZrpgWa6oRIRviolvNxePENLl8vjHxcb+R8Xt5dJhU4dl2ybKoiyZhwoXc/ec7poI6v86x9H6Yxnqmw",
|
||||
"pHRjqKLWi6ioii+9J69OlVgOZTiufN3CJHAWBS5a8TGJIwZJYX5LGNiS5Z1iZhOV9TlhgCM8iKFsW2ff",
|
||||
"Z9kWQNK6ev31xgKCEgrlNsyZRcGgWQNmFlBrpNz4edBsfcBOBQCrwQtKaa4SUJBkmgrvaF+zkGm5d87b",
|
||||
"bx75NBVlLK6oFN9SSOF0KIDVl9OfEfkY0BZDn7oBvWxbpq01VLlpYFMSKNWKTDLkZFxXRiVFsXjDEvP0",
|
||||
"5fTm5uLD9dX59W3QCvQ/Ki5ZK2y5zVJrRVOygc3cahnWtbOlFcu0LPGphXEFMhjZqEgY1THg8vSlJt6X",
|
||||
"7VdIfKZcM17V+o4D0z0+poOYhFUCU+MZ9pcJrG/maAH8+6fr875E6tnVxXXQCq7Or96d970gvOM+ecME",
|
||||
"k9iPA/UK4ShiwLkFhGS2kA3RA3joqRd/ACND4ku3fBqDGAPLBkVjzNGjaS5/JazIgQPCAaUx4GRD+RBP",
|
||||
"PoZwGcoWVMlOvLYeWMEU5eBbYLkyl3REkvKweTurtELNQw80V66U8yfKSgJF+7ZafCswkJFdqLjYOWYt",
|
||||
"ymTdhxHhQv59ReKuZ/BLULqDq2XcRO1Fc60gH5Mp34HCQcGVPQ8cpbRGtK3XLejLcZUQFlzDC9rkbZg8",
|
||||
"Tcy3bJ9UlFe2f+Z+RsxLXR/UcSIKcYKmwOT8JD/1I/cYc/ErYCYGgMVpxW6zQE4V3jkkAmE0tr07mz3F",
|
||||
"sPXQT8+l49+ZhJCIGycr6tvoyzZq660qIPmhnXzg9XKpSyLIckDtgOIbZHtLhjYTu5k6kM3Bdkpy+yXL",
|
||||
"J9/4hqg1O1MP8ClT80z0iwC9VELWN3m0Ho9Wl5Cd4y32mh1TaGqGJzneH7pjdiRjEwojx/WrzFrJxRfW",
|
||||
"NqVRPpGUztmbvNtSKgxHEZFTxPFHh5xgKXgY1MmL+tPPE2bPcbbGAm4tBeWeSMjSUNX5I0ZGI2AQvZs1",
|
||||
"GPzW6eUUvIwGNVQ4zwjrl83+cMrNRnbFyd5Xo3dH/Jxjyxsp39aKgCUg8BxcpclHle8tAZ5scBOOIUpj",
|
||||
"/8EIsGf0ap0eMpWj7dRxGsIx61SFMem9POfVY20h1w9P1vbf/i2j5rByYhoW75mE/tCPjIrywBdSIuxl",
|
||||
"BE3tc1hS9/xiDndumiz3z7C5mj+Tm6+U9LhQPmkwcCafzfoybXv94svN8RcTlTUXs+NTilK28fc6UfU6",
|
||||
"dS4WPStIkUQcH3lPCAgHKg1WjDvhrF+VzctaBuHJ2RrVDfhsn4YG0PJspVQY6H75Yp+BDAiFd9kZfiq+",
|
||||
"9myf8RP61+nVJYqyhs3tXZFODab9FzheCGF/A5TIIBjClBExk3HDRMt3AJgBO03FOLsUpooU6ud8gmMh",
|
||||
"VJk1pPSBgG1OpIT0T3Yj1wsWLjjhKVGnqOdq0zGkfiHbu2SnHy9kVyJUqqr4a7ZKwWHnoHOgFnkKCZ6S",
|
||||
"oBccdw47Byp6EGM1tS6eku7jYVeb/e4P9XfetWgagSel9gGEvvNlD8XjJD+sLnGpQlK5UPlh+w9qslPM",
|
||||
"8ASEslKfvdlPdbReHflRcpN85lLT0Zq71noDpvFSQPEq54bm96qmrwJpJZyjgwMdMCXChInm1pjkuPvV",
|
||||
"nOHIqS8NItW1A7XGxanfpGEInA/TOJ4hBoIReNQ1MiMRtR7zVnCyQY7yW2oejk7RBMdSmhAhytAAR4iZ",
|
||||
"Yopi4/hl2PiFsgGJIki0atoD8AqCjmRsGuizuXRz3wq+t+1VK/W7KQHbiP9eDmexr9/pGItyD+D1jSiO",
|
||||
"MErgCWVDFaGuM/66qcEocPGORrONicp3M8sjtNv8To6g5oregtbMt4h1W0lfAnRzO8I5hvAXh3gThOu1",
|
||||
"zsFmAW5ku4BwH6K7P/TDvJtH9V6Lfkm44AjHsVYqXQvAztkQj1VXyYsaJt0gscymZxPcllFvVVwDERTx",
|
||||
"BzK1nH1Lgc1y1uhwyJXb8rBSfmy2mlxMJkSgwayEpHq9LsVTdehXRmIPMOOS6pDEAlg5WdmuQHXdu19e",
|
||||
"KXB11Qkp2g5XQ3VF3ceW7lBgbCk/5j6Vh4VP6hIuRSoQLJcFde9yNSJduAVWIgNNPMoumlXycOY0a85H",
|
||||
"3vsFIhtlDZYZfAlLN6zh+5AmN/hSglYsteOZOla/q7S7punXJqOG+bfXT1+BB9g6+K0smuJfCXuvAz4d",
|
||||
"QMYlbVIPmLq+Uh7m6+stMsy3/lN3LNGAO/UVBd3p1ajB5jclnktBJXsSu7lXIQmzcnu5bUl9R6WZ27uq",
|
||||
"EjXVS75hZ/WUnSUrTTpJL6WbFV3Ugn46x4j+5v7JkUSzvJNNk+6B/yztZADowN6cFVsD91LQbZYmvPvD",
|
||||
"/XderQ3ZGiGWJssVwlTUa2Zid3LbXphwGWuuBF+x1manMlZSWymhveYuam4mm6L6qipTRda4gKl6+sxr",
|
||||
"uTLVsp7u7t1Zrhh7h7Z5teCNdKKmEnSZOQhZSxPyg+h1PNk+A72rGWh3tydpjkBkS9spIWwP171UCFGf",
|
||||
"M+fEwKsLH9YwlEoue2NZHkOsYTBTDox3zcdmqswjR+5XacxF4qJFvOPAPoB4bwbbIq7UBeNmYFIc7xKG",
|
||||
"Dl+GjbsEp2JMGfkPRJrwTy9D+ArEmEYoocqz0if76VRzqkm5SPeA0ud7aYqKIH8GN4txtfweGMd0RJLy",
|
||||
"tOolHXFEEoSz64aL+NW5VHVFektnJxauYM/NhdU/U1diOhpBhEiyV5GdUpGCRijUNNAF89GjCmWgqain",
|
||||
"DXKoHcGoZGUP0tdjxzV66sJ2kt+6r1EpNhsqp1P20eLKSMV/w3/LAPcTbVCqXZztPiiuD0PChU+CyyHJ",
|
||||
"zDc8quq1ugWvNKZbPZHp+9jILgQWVnj7KPxVhBgWQsvNtak+6ToRsDoVIo8h1hWrmpUg882MqnKL/rzV",
|
||||
"qy2PrpAg2TF92pm6aIOyqP1I4CLAdeY4K4XWLoPWShw3QL3JE1aXGV95JWXF5OAe/f684Ip1xeU60HU/",
|
||||
"OVJHGeyFvFpKYa4XviLdqE7um8l30MVQOWGeSkhA1FIgjrEALjIJEY6GIMIxRGUVgPwW4WtS7ezTF6ul",
|
||||
"/x/zL2f8jTVdUj15GarXVKAhTZOoqu6QQ3HLdqYbFW5ANzE5zpXohtbHuQ29t0N/MTvkrO16FsnB1944",
|
||||
"7aJxchdodTv1PM3k3sL/fC8Vz5N4AvZo7UXK4qAXBPP7+X8DAAD//8uL4W3XdQAA",
|
||||
}
|
||||
|
||||
// GetSwagger returns the content of the embedded swagger specification file
|
||||
|
||||
@@ -2,11 +2,8 @@ package transformers
|
||||
|
||||
import (
|
||||
"context"
|
||||
"fmt"
|
||||
|
||||
"github.com/hatchet-dev/hatchet/api/v1/server/oas/gen"
|
||||
"github.com/hatchet-dev/hatchet/internal/datautils"
|
||||
"github.com/hatchet-dev/hatchet/internal/iter"
|
||||
"github.com/hatchet-dev/hatchet/internal/repository"
|
||||
"github.com/hatchet-dev/hatchet/internal/repository/prisma/db"
|
||||
"github.com/hatchet-dev/hatchet/internal/repository/prisma/dbsqlc"
|
||||
@@ -168,19 +165,7 @@ func ToWorkflowYAMLBytes(workflow *db.WorkflowModel, version *db.WorkflowVersion
|
||||
if steps := jobCp.Steps(); steps != nil {
|
||||
jobRes.Steps = make([]types.WorkflowStep, 0)
|
||||
|
||||
iter, err := iter.New(steps)
|
||||
|
||||
if err != nil {
|
||||
return nil, fmt.Errorf("could not create step iterator: %w", err)
|
||||
}
|
||||
|
||||
for {
|
||||
step, ok := iter.Next()
|
||||
|
||||
if !ok {
|
||||
break
|
||||
}
|
||||
|
||||
for _, step := range steps {
|
||||
stepRes := types.WorkflowStep{
|
||||
ID: step.ID,
|
||||
ActionID: step.ActionID,
|
||||
@@ -194,17 +179,6 @@ func ToWorkflowYAMLBytes(workflow *db.WorkflowModel, version *db.WorkflowVersion
|
||||
stepRes.Timeout = timeout
|
||||
}
|
||||
|
||||
if inputs, ok := step.Inputs(); ok {
|
||||
withMap := map[string]interface{}{}
|
||||
err := datautils.FromJSONType(&inputs, &withMap)
|
||||
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
stepRes.With = withMap
|
||||
}
|
||||
|
||||
jobRes.Steps = append(jobRes.Steps, stepRes)
|
||||
}
|
||||
|
||||
@@ -237,20 +211,9 @@ func ToJob(job *db.JobModel) (*gen.Job, error) {
|
||||
if steps := job.Steps(); steps != nil {
|
||||
apiSteps := make([]gen.Step, 0)
|
||||
|
||||
iter, err := iter.New(steps)
|
||||
|
||||
if err != nil {
|
||||
return nil, fmt.Errorf("could not create step iterator: %w", err)
|
||||
}
|
||||
|
||||
for {
|
||||
step, ok := iter.Next()
|
||||
|
||||
if !ok {
|
||||
break
|
||||
}
|
||||
|
||||
apiSteps = append(apiSteps, *ToStep(step))
|
||||
for _, step := range steps {
|
||||
stepCp := step
|
||||
apiSteps = append(apiSteps, *ToStep(&stepCp))
|
||||
}
|
||||
|
||||
res.Steps = apiSteps
|
||||
@@ -277,10 +240,26 @@ func ToStep(step *db.StepModel) *gen.Step {
|
||||
res.Timeout = repository.StringPtr(defaults.DefaultStepRunTimeout)
|
||||
}
|
||||
|
||||
if next, ok := step.NextID(); ok {
|
||||
res.NextId = next
|
||||
parents := []string{}
|
||||
|
||||
if step.RelationsStep.Parents != nil {
|
||||
for _, parent := range step.Parents() {
|
||||
parents = append(parents, parent.ID)
|
||||
}
|
||||
}
|
||||
|
||||
res.Parents = &parents
|
||||
|
||||
children := []string{}
|
||||
|
||||
if step.RelationsStep.Children != nil {
|
||||
for _, child := range step.Children() {
|
||||
children = append(children, child.ID)
|
||||
}
|
||||
}
|
||||
|
||||
res.Children = &children
|
||||
|
||||
return res
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user