Skip to content

Commit

Permalink
nit
Browse files Browse the repository at this point in the history
Signed-off-by: Kevin Su <[email protected]>
  • Loading branch information
pingsutw committed Feb 20, 2024
1 parent 779b336 commit a46196d
Showing 1 changed file with 6 additions and 0 deletions.
6 changes: 6 additions & 0 deletions flyteplugins/go/tasks/plugins/webapi/agent/client.go
Original file line number Diff line number Diff line change
Expand Up @@ -136,6 +136,12 @@ func initializeAgentRegistry(cs *ClientSet) (Registry, error) {
}

for _, agent := range res.GetAgents() {
deprecatedSupportedTaskTypes := agent.DeprecatedSupportedTaskTypes
for _, supportedTaskType := range deprecatedSupportedTaskTypes {
agent := &Agent{AgentDeployment: agentDeployment, IsSync: agent.IsSync}
agentRegistry[supportedTaskType] = map[int32]*Agent{defaultTaskTypeVersion: agent}
}

Check warning on line 143 in flyteplugins/go/tasks/plugins/webapi/agent/client.go

View check run for this annotation

Codecov / codecov/patch

flyteplugins/go/tasks/plugins/webapi/agent/client.go#L141-L143

Added lines #L141 - L143 were not covered by tests

supportedTaskTypes := agent.SupportedTaskTypes
for _, supportedTaskType := range supportedTaskTypes {
agent := &Agent{AgentDeployment: agentDeployment, IsSync: agent.IsSync}
Expand Down

0 comments on commit a46196d

Please sign in to comment.