-
Notifications
You must be signed in to change notification settings - Fork 87
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
flow improvements #715
flow improvements #715
Conversation
/hold |
/test |
🔥 Oops, something went wrong @kon-angelo Command test Runs a testrun that is either specified by command line flags or in the default values. The specified path is rendered as testrun and the current repository is injected as a default location. Example: /test [sub-command] [--flags] Usage: --dry-run Print the rendered testrun --set stringArray sets additional helm values --template run go templating on the configured file before execution --testrunPath string path to the testrun file that should be executed
|
/test |
Testrun: e2e-gpfp2 +---------------------+---------------------+-----------+----------+ | NAME | STEP | PHASE | DURATION | +---------------------+---------------------+-----------+----------+ | infrastructure-test | infra-flow-test | Failed | 12m4s | | infrastructure-test | infra-migrate-test | Failed | 13m15s | | bastion-test | bastion-test | Succeeded | 11m12s | | infrastructure-test | infrastructure-test | Failed | 11m35s | +---------------------+---------------------+-----------+----------+ |
@kon-angelo Label kind/enhancements does not exist. |
/test |
Testrun: e2e-tzvmv +---------------------+---------------------+-----------+----------+ | NAME | STEP | PHASE | DURATION | +---------------------+---------------------+-----------+----------+ | bastion-test | bastion-test | Succeeded | 10m28s | | infrastructure-test | infra-migrate-test | Succeeded | 11m45s | | infrastructure-test | infrastructure-test | Succeeded | 10m34s | | infrastructure-test | infra-flow-test | Succeeded | 11m4s | +---------------------+---------------------+-----------+----------+ |
/test |
Testrun: e2e-zk2j6 +---------------------+---------------------+-----------+----------+ | NAME | STEP | PHASE | DURATION | +---------------------+---------------------+-----------+----------+ | bastion-test | bastion-test | Succeeded | 10m7s | | infrastructure-test | infra-flow-test | Succeeded | 11m7s | | infrastructure-test | infra-migrate-test | Succeeded | 11m47s | | infrastructure-test | infrastructure-test | Succeeded | 10m38s | +---------------------+---------------------+-----------+----------+ |
/unhold |
pkg/controller/infrastructure/infraflow/shared/basic_context.go
Outdated
Show resolved
Hide resolved
pkg/controller/infrastructure/infraflow/shared/basic_context.go
Outdated
Show resolved
Hide resolved
delta := int(time.Since(w.start).Seconds()) | ||
w.log.Info(fmt.Sprintf("%s [%ds]", w.message.Load(), delta), w.keysAndValues...) | ||
delta := time.Since(w.start) | ||
w.log.Info(fmt.Sprintf("%s [%s]", w.message.Load(), delta.Round(time.Second).String()), w.keysAndValues...) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
w.log.Info(fmt.Sprintf("%s [%s]", w.message.Load(), delta.Round(time.Second).String()), w.keysAndValues...) | |
w.log.Info(fmt.Sprintf("%s [%.2f s]", w.message.Load(), delta.Seconds()), w.keysAndValues...) |
Just an Idea, feel free to discard.
return fmt.Errorf("failed to create flow context: %v", err) | ||
} | ||
|
||
status, state, err := fctx.Reconcile(ctx) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Can we maybe come up with something more meaningful then status and state.
Some suggestions: privState, currentState, progState, progress...
/test |
Testrun: e2e-xp895 +---------------------+---------------------+-----------+----------+ | NAME | STEP | PHASE | DURATION | +---------------------+---------------------+-----------+----------+ | bastion-test | bastion-test | Succeeded | 8m24s | | infrastructure-test | infrastructure-test | Failed | 2m29s | | infrastructure-test | infra-flow-test | Omitted | 0s | | infrastructure-test | infra-migrate-test | Omitted | 0s | +---------------------+---------------------+-----------+----------+ |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
lgtm
vpcName := fctx.vpcNameFromConfig() | ||
|
||
routes, err := fctx.computeClient.ListRoutes(ctx, client.RouteListOpts{ | ||
// Filter: fmt.Sprintf("network~'%s'", vpcName), |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Leftover from development? If so rm. If this is here for future reference consider adding a few words as to why
for _, name := range names { | ||
log.Info(fmt.Sprintf("destroying route[name=%s]", name)) | ||
err := c.computeClient.DeleteRoute(ctx, name) | ||
log.Info(fmt.Sprintf("destroying route[name=%s]", route.Name)) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
missing whitespace in route[name=…
// Data: map[string]string{ | ||
// | ||
// CreatedResourcesExistKey: ptr.Deref(fctx.whiteboard.Get(CreatedResourcesExistKey), ""), | ||
// }, |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Rm, unless you plan to use it in future
@@ -271,6 +271,7 @@ func IsValidValue(value string) bool { | |||
return value != "" && value != deleted | |||
} | |||
|
|||
// ObjectKeys returns a slice containing the keys of the Whiteboard in ascending order. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
That should be in l.287 I think
/test |
Testrun: e2e-9cmvf +---------------------+---------------------+-----------+----------+ | NAME | STEP | PHASE | DURATION | +---------------------+---------------------+-----------+----------+ | bastion-test | bastion-test | Succeeded | 7m56s | | infrastructure-test | infrastructure-test | Succeeded | 8m18s | | infrastructure-test | infra-flow-test | Succeeded | 8m32s | | infrastructure-test | infra-migrate-test | Succeeded | 8m39s | +---------------------+---------------------+-----------+----------+ |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
lgtm
How to categorize this PR?
/area control-plane
/kind enhancement
/platform gcp
What this PR does / why we need it:
Which issue(s) this PR fixes:
Fixes #
Special notes for your reviewer:
Release note: