services/snapshoter-bq-app/src/main/java/com/google/cloud/pso/bq_snapshot_manager/snapshoter_bq/BigQuerySnapshoterController.java [108:145]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
            snapshoterResponse = snapshoter.execute(
                    snapshoterRequest,
                    Timestamp.now(),
                    requestBody.getMessage().getMessageId());

            responseEntity = new ResponseEntity("Process completed successfully.", HttpStatus.OK);
            isSuccess = true;

        } catch (Exception e) {
            Tuple<ResponseEntity, Boolean> handlingResults  = ControllerExceptionHelper.handleException(
                    e,
                    logger,
                    trackingId,
                    snapshoterRequest == null? null: snapshoterRequest.getTargetTable()
                    );
            isSuccess = false;
            responseEntity = handlingResults.x();
            isRetryableError = handlingResults.y();
            error = e;
        }

        logger.logUnified(
                snapshoterRequest == null? null: snapshoterRequest.isDryRun(),
                functionNumber.toString(),
                snapshoterRequest == null? null: snapshoterRequest.getRunId(),
                snapshoterRequest == null? null: snapshoterRequest.getTrackingId(),
                snapshoterRequest == null? null : snapshoterRequest.getTargetTable(),
                snapshoterRequest,
                snapshoterResponse,
                isSuccess,
                error,
                isRetryableError
        );

        return responseEntity;
    }

    public static void main(String[] args) {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



services/snapshoter-gcs-app/src/main/java/com/google/cloud/pso/bq_snapshot_manager/snapshoter_gcs/GCSSnapshoterController.java [113:150]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
            snapshoterResponse = snapshoter.execute(
                    snapshoterRequest,
                    Timestamp.now(),
                    requestBody.getMessage().getMessageId());

            responseEntity = new ResponseEntity("Process completed successfully.", HttpStatus.OK);
            isSuccess = true;

        } catch (Exception e) {
            Tuple<ResponseEntity, Boolean> handlingResults  = ControllerExceptionHelper.handleException(
                    e,
                    logger,
                    trackingId,
                    snapshoterRequest == null? null: snapshoterRequest.getTargetTable()
            );
            isSuccess = false;
            responseEntity = handlingResults.x();
            isRetryableError = handlingResults.y();
            error = e;
        }

        logger.logUnified(
                snapshoterRequest == null? null: snapshoterRequest.isDryRun(),
                functionNumber.toString(),
                snapshoterRequest == null? null: snapshoterRequest.getRunId(),
                snapshoterRequest == null? null: snapshoterRequest.getTrackingId(),
                snapshoterRequest == null? null : snapshoterRequest.getTargetTable(),
                snapshoterRequest,
                snapshoterResponse,
                isSuccess,
                error,
                isRetryableError
        );

        return responseEntity;
    }

    public static void main(String[] args) {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -