exec

Documentation

Index

• Constants
• func RunWithRetries(f func() error, maxRetries int) (err error)
• func WaitForJobCompletion(ctx context.Context, service *bigquery.Service, projectID string, ...) (*bigquery.Job, error)

Constants

const (
	//StatusDone status done
	StatusDone = "DONE"
)

Functions

func RunWithRetries

func RunWithRetries(f func() error, maxRetries int) (err error)

RunWithRetries run with exp backoff retries on http.StatusInternalServerError, http.StatusServiceUnavailable, http.StatusBadGateway

func WaitForJobCompletion

func WaitForJobCompletion(ctx context.Context, service *bigquery.Service, projectID string, location, jobReferenceID string) (*bigquery.Job, error)

WaitForJobCompletion waits for job completion