Skip to content

Commit

Permalink
test
Browse files Browse the repository at this point in the history
Signed-off-by: Haytham Abuelfutuh <[email protected]>
  • Loading branch information
EngHabu committed Jan 24, 2024
1 parent 90bacf7 commit 0721a7e
Showing 1 changed file with 0 additions and 31 deletions.
31 changes: 0 additions & 31 deletions flytepropeller/pkg/controller/nodes/output_resolver_test.go
Original file line number Diff line number Diff line change
@@ -1,12 +1,8 @@
package nodes

import (
"os"
"testing"

protoV1 "github.com/golang/protobuf/proto"
"google.golang.org/protobuf/proto"

"github.com/stretchr/testify/assert"

"github.com/flyteorg/flyte/flyteidl/gen/pb-go/flyteidl/core"
Expand All @@ -33,30 +29,3 @@ func TestCreateAliasMap(t *testing.T) {
assert.Equal(t, map[string]string{}, m)
}
}

func TestOutputTemp(t *testing.T) {
f, err := os.ReadFile("/Users/haytham/Downloads/outputs.pb")
assert.NoError(t, err)

msg := []protoV1.Message{&core.OutputData{}, &core.LiteralMap{}}
var lastErr error
var index int
for i, m := range msg {
err = proto.UnmarshalOptions{DiscardUnknown: false, AllowPartial: false}.Unmarshal(f, protoV1.MessageV2(m))
if err != nil {
lastErr = err
continue
}

if len(msg) == 1 || len(protoV1.MessageV2(m).ProtoReflect().GetUnknown()) == 0 {
index = i
lastErr = nil
break
}
}

assert.NoError(t, lastErr)
t.Log(index)
t.Log(msg[index])
t.FailNow()
}

0 comments on commit 0721a7e

Please sign in to comment.