Skip to content

Commit

Permalink
lint fix
Browse files Browse the repository at this point in the history
  • Loading branch information
k-anshul committed Dec 19, 2023
1 parent 8800def commit d75e70e
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 10 deletions.
8 changes: 3 additions & 5 deletions runtime/reconcilers/model.go
Original file line number Diff line number Diff line change
Expand Up @@ -221,11 +221,9 @@ func (r *ModelReconciler) Reconcile(ctx context.Context, n *runtimev1.ResourceNa
createErr := r.createModel(ctx, self, stagingTableName, !materialize)
if createErr != nil {
createErr = fmt.Errorf("failed to create model: %w", createErr)
} else {
if !r.C.Runtime.AllowHostAccess() {
// temporarily for debugging
logTableNameAndType(ctx, r.C, connector, stagingTableName)
}
} else if !r.C.Runtime.AllowHostAccess() {
// temporarily for debugging
logTableNameAndType(ctx, r.C, connector, stagingTableName)
}

if createErr == nil && stage {
Expand Down
8 changes: 3 additions & 5 deletions runtime/reconcilers/source.go
Original file line number Diff line number Diff line change
Expand Up @@ -179,11 +179,9 @@ func (r *SourceReconciler) Reconcile(ctx context.Context, n *runtimev1.ResourceN
ingestErr := r.ingestSource(ctx, src.Spec, stagingTableName)
if ingestErr != nil {
ingestErr = fmt.Errorf("failed to ingest source: %w", ingestErr)
} else {
if !r.C.Runtime.AllowHostAccess() {
// temporarily for debugging
logTableNameAndType(ctx, r.C, connector, stagingTableName)
}
} else if !r.C.Runtime.AllowHostAccess() {
// temporarily for debugging
logTableNameAndType(ctx, r.C, connector, stagingTableName)
}

if ingestErr == nil && src.Spec.StageChanges {
Expand Down

0 comments on commit d75e70e

Please sign in to comment.