@@ -436,6 +436,10 @@ func GetWorkflowVersionByID(versionID, fleetID uuid.UUID) *types.WorkflowVersion
436436 return & workflowVersion
437437}
438438
439+ type Parallelism struct {
440+ Parallelism int `json:"parallelism"`
441+ }
442+
439443func GetWorkflowVersionMaxMachines (version string , fleet uuid.UUID ) (types.Machines , error ) {
440444 resp := request .Trickest .Get ().DoF ("workflow-version/%s/max-machines/?fleet=%s" , version , fleet )
441445 if resp == nil {
@@ -446,12 +450,16 @@ func GetWorkflowVersionMaxMachines(version string, fleet uuid.UUID) (types.Machi
446450 return types.Machines {}, fmt .Errorf ("unexpected response status code for workflow version's maximum machines: %d" , resp .Status ())
447451 }
448452
449- var machines types. Machines
450- err := json .Unmarshal (resp .Body (), & machines )
453+ var parallelism Parallelism
454+ err := json .Unmarshal (resp .Body (), & parallelism )
451455 if err != nil {
452456 return types.Machines {}, fmt .Errorf ("couldn't unmarshal workflow versions's maximum machines: %v" , err )
453457 }
454458
459+ machines := types.Machines {
460+ Default : & parallelism .Parallelism ,
461+ }
462+
455463 return machines , nil
456464}
457465
@@ -744,7 +752,7 @@ func FormatDuration(duration time.Duration) string {
744752}
745753
746754func DownloadFile (url , outputDir , fileName string ) error {
747- err := os .MkdirAll (outputDir , 0755 )
755+ err := os .MkdirAll (outputDir , 0o755 )
748756 if err != nil {
749757 return fmt .Errorf ("couldn't create output directory (%s): %w" , outputDir , err )
750758 }
0 commit comments