Skip to content

creating all normalized tables in a single activity - #325

Merged
iskakaushik merged 9 commits into
mainfrom
normalize-tables-create-parallel
Aug 16, 2023
Merged

creating all normalized tables in a single activity#325
iskakaushik merged 9 commits into
mainfrom
normalize-tables-create-parallel

Conversation

@heavycrystal

Copy link
Copy Markdown
Contributor

No description provided.

Comment thread flow/connectors/snowflake/snowflake.go Outdated
Comment thread flow/connectors/postgres/postgres.go Outdated
tableAlreadyExists, err := c.tableExists(normalizedTableNameComponents)
func (c *PostgresConnector) SetupNormalizedTables(
req *protos.SetupNormalizedTableParallelInput,
) (*protos.SetupNormalizedTableParallelOutput, error) {

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

🚫 [golangci] reported by reviewdog 🐶
unnecessary leading newline (whitespace)

Comment thread flow/connectors/snowflake/snowflake.go Outdated
}, nil
}
func (c *SnowflakeConnector) SetupNormalizedTables(
req *protos.SetupNormalizedTableParallelInput) (*protos.SetupNormalizedTableParallelOutput, error) {

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

🚫 [golangci] reported by reviewdog 🐶
unnecessary leading newline (whitespace)

Comment thread flow/connectors/bigquery/bigquery.go Outdated
Repeated: strings.Contains(genericColType, "array"),
func (c *BigQueryConnector) SetupNormalizedTables(
req *protos.SetupNormalizedTableParallelInput,
) (*protos.SetupNormalizedTableParallelOutput, error) {

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

🚫 [golangci] reported by reviewdog 🐶
unnecessary leading newline (whitespace)

Comment thread flow/workflows/setup_flow.go Outdated
var createNormalizedTablesOutput protos.SetupNormalizedTableParallelOutput
if err := future.Get(ctx, &createNormalizedTablesOutput); err != nil {
s.logger.Error("failed to create normalized tables: ", err)
return nil, fmt.Errorf("failed to create normalized tables: ", err)

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

🚫 [golangci] reported by reviewdog 🐶
printf: fmt.Errorf call has arguments but no formatting directives (govet)

Comment thread flow/connectors/postgres/postgres.go Outdated
Comment thread flow/connectors/bigquery/bigquery.go Outdated
Repeated: strings.Contains(genericColType, "array"),
func (c *BigQueryConnector) SetupNormalizedTables(
req *protos.SetupNormalizedTableParallelInput,
) (*protos.SetupNormalizedTableParallelOutput, error) {

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

🚫 [golangci] reported by reviewdog 🐶
unnecessary leading newline (whitespace)

Comment thread flow/workflows/setup_flow.go Outdated
var createNormalizedTablesOutput protos.SetupNormalizedTableParallelOutput
if err := future.Get(ctx, &createNormalizedTablesOutput); err != nil {
s.logger.Error("failed to create normalized tables: ", err)
return nil, fmt.Errorf("failed to create normalized tables: ", err)

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

🚫 [golangci] reported by reviewdog 🐶
printf: fmt.Errorf call has arguments but no formatting directives (govet)

@iskakaushik
iskakaushik merged commit b04f64e into main Aug 16, 2023
@claude claude Bot mentioned this pull request Aug 13, 2026
1 task
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants