diff --git a/cmd/s3_to_db.go b/cmd/s3_to_db.go index a9d4e91..9430b21 100644 --- a/cmd/s3_to_db.go +++ b/cmd/s3_to_db.go @@ -129,6 +129,7 @@ func bucket_to_cgov_tables( pg_restore := pipes.PG_Restore(db_creds, schema, table) restoreOut, restoreError := pg_restore.String() util.ErrorCheck(restoreOut, restoreError) + logging.Logger.Printf("RESTORE of table %s complete.", table) os.Remove(fmt.Sprintf("./pg_dump_tables/%s", dump_file_name)) logging.Logger.Printf("REMOVING FILE: %s", dump_file_name) diff --git a/internal/pipes/pg_restore.go b/internal/pipes/pg_restore.go index 4d3000f..7360d72 100644 --- a/internal/pipes/pg_restore.go +++ b/internal/pipes/pg_restore.go @@ -33,7 +33,7 @@ func PG_Restore(creds vcap.Credentials, schema string, table string) *script.Pip // Combine the slice for printing and execution. combined := strings.Join(cmd[:], " ") logging.Logger.Printf("RESTORE "+util.PGRESTORE_path+" targeting %s.%s\n", schema, table) - logging.Logger.Printf("CALLING COMMAND: " + combined) + //logging.Logger.Printf("CALLING COMMAND: " + combined) if util.IsDebugLevel("DEBUG") { fmt.Printf("command: %s\n", combined) }