Skip to content

Commit

Permalink
Remove , file in the root directory (#4983)
Browse files Browse the repository at this point in the history
Signed-off-by: Future-Outlier <[email protected]>
  • Loading branch information
Future-Outlier authored Mar 10, 2024
1 parent a49284e commit 6a68552
Show file tree
Hide file tree
Showing 8 changed files with 8 additions and 7 deletions.
Empty file removed ,
Empty file.
Original file line number Diff line number Diff line change
Expand Up @@ -2,9 +2,9 @@ package webapi

import (
"context"
pluginErrors "github.com/flyteorg/flyte/flyteplugins/go/tasks/errors"
"time"

pluginErrors "github.com/flyteorg/flyte/flyteplugins/go/tasks/errors"
"github.com/flyteorg/flyte/flyteplugins/go/tasks/pluginmachinery/core"
"github.com/flyteorg/flyte/flyteplugins/go/tasks/pluginmachinery/webapi"
"github.com/flyteorg/flyte/flytestdlib/cache"
Expand Down
2 changes: 1 addition & 1 deletion flyteplugins/go/tasks/plugins/webapi/agent/plugin.go
Original file line number Diff line number Diff line change
Expand Up @@ -4,13 +4,13 @@ import (
"context"
"encoding/gob"
"fmt"
"github.com/flyteorg/flyte/flyteidl/gen/pb-go/flyteidl/service"
"time"

"golang.org/x/exp/maps"

"github.com/flyteorg/flyte/flyteidl/gen/pb-go/flyteidl/admin"
flyteIdl "github.com/flyteorg/flyte/flyteidl/gen/pb-go/flyteidl/core"
"github.com/flyteorg/flyte/flyteidl/gen/pb-go/flyteidl/service"
pluginErrors "github.com/flyteorg/flyte/flyteplugins/go/tasks/errors"
"github.com/flyteorg/flyte/flyteplugins/go/tasks/pluginmachinery"
"github.com/flyteorg/flyte/flyteplugins/go/tasks/pluginmachinery/core"
Expand Down
3 changes: 2 additions & 1 deletion flytepropeller/events/local_eventsink.go
Original file line number Diff line number Diff line change
Expand Up @@ -7,8 +7,9 @@ import (
"os"
"sync"

"github.com/flyteorg/flyte/flyteidl/gen/pb-go/flyteidl/event"
"github.com/golang/protobuf/proto"

"github.com/flyteorg/flyte/flyteidl/gen/pb-go/flyteidl/event"
)

type localSink struct {
Expand Down
2 changes: 1 addition & 1 deletion flytepropeller/pkg/compiler/test/compiler_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,6 @@ import (
"bytes"
"encoding/json"
"flag"
"github.com/flyteorg/flyte/flytepropeller/pkg/visualize"
"io/ioutil"
"os"
"path/filepath"
Expand All @@ -27,6 +26,7 @@ import (
"github.com/flyteorg/flyte/flytepropeller/pkg/compiler/common"
"github.com/flyteorg/flyte/flytepropeller/pkg/compiler/errors"
"github.com/flyteorg/flyte/flytepropeller/pkg/compiler/transformers/k8s"
"github.com/flyteorg/flyte/flytepropeller/pkg/visualize"
)

var update = flag.Bool("update", false, "Update .golden files")
Expand Down
2 changes: 1 addition & 1 deletion flytepropeller/pkg/compiler/validators/utils_test.go
Original file line number Diff line number Diff line change
@@ -1,9 +1,9 @@
package validators

import (
"github.com/golang/protobuf/proto"
"testing"

"github.com/golang/protobuf/proto"
"github.com/stretchr/testify/assert"

"github.com/flyteorg/flyte/flyteidl/clients/go/coreutils"
Expand Down
2 changes: 1 addition & 1 deletion flytepropeller/pkg/compiler/workflow_compiler_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -2,10 +2,10 @@ package compiler

import (
"fmt"
"github.com/golang/protobuf/proto"
"strings"
"testing"

"github.com/golang/protobuf/proto"
"github.com/stretchr/testify/assert"
"k8s.io/apimachinery/pkg/util/sets"

Expand Down
2 changes: 1 addition & 1 deletion flytepropeller/pkg/controller/nodes/executor.go
Original file line number Diff line number Diff line change
Expand Up @@ -791,7 +791,7 @@ func isTimeoutExpired(queuedAt *metav1.Time, timeout time.Duration) bool {
return false
}

func (c *nodeExecutor) isEligibleForRetry(nCtx interfaces.NodeExecutionContext, nodeStatus v1alpha1.ExecutableNodeStatus, err *core.ExecutionError) (currentAttempt, maxAttempts uint32, isEligible bool) {
func (c *nodeExecutor) isEligibleForRetry(nCtx interfaces.NodeExecutionContext, nodeStatus v1alpha1.ExecutableNodeStatus, err *core.ExecutionError) (currentAttempt uint32, maxAttempts uint32, isEligible bool) {
if config.GetConfig().NodeConfig.IgnoreRetryCause {
currentAttempt = nodeStatus.GetAttempts() + 1
} else {
Expand Down

0 comments on commit 6a68552

Please sign in to comment.