cdk/cdk/afc_lambdas/create_predictor_backtest_export.py [33:62]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
def create_predictor_backtest_export_handler(event, context):
    """
    """

    payload = event["input"]["Payload"]
    prefix = payload["prefix"]

    update_status_json(payload, "IN_PROGRESS:create_predictor_backtest_export",
        payload["StatusJsonS3Path"])

    backtest_export_job_name = f"{prefix}_BacktestExportJob"

    resp = afc.create_predictor_backtest_export_job(
        PredictorBacktestExportJobName=backtest_export_job_name,
        PredictorArn=payload["PredictorArn"],
        Destination={
            "S3Config": {
                "Path": os.path.join(payload["s3_export_path"], prefix),
                "RoleArn": os.environ["AFC_ROLE_ARN"],
            }
        }
    )

    resp_out = payload
    resp_out["PredictorBacktestExportJobArn"] = resp["PredictorBacktestExportJobArn"]

    update_status_json(resp_out, "IN_PROGRESS:create_predictor_backtest_export",
        payload["StatusJsonS3Path"])

    return resp_out
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



cdk/cdk/afc_lambdas/index.py [240:269]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
def create_predictor_backtest_export_handler(event, context):
    """
    """

    payload = event["input"]["Payload"]
    prefix = payload["prefix"]

    update_status_json(payload, "IN_PROGRESS:create_predictor_backtest_export",
        payload["StatusJsonS3Path"])

    backtest_export_job_name = f"{prefix}_BacktestExportJob"

    resp = afc.create_predictor_backtest_export_job(
        PredictorBacktestExportJobName=backtest_export_job_name,
        PredictorArn=payload["PredictorArn"],
        Destination={
            "S3Config": {
                "Path": os.path.join(payload["s3_export_path"], prefix),
                "RoleArn": os.environ["AFC_ROLE_ARN"],
            }
        }
    )

    resp_out = payload
    resp_out["PredictorBacktestExportJobArn"] = resp["PredictorBacktestExportJobArn"]

    update_status_json(resp_out, "IN_PROGRESS:create_predictor_backtest_export",
        payload["StatusJsonS3Path"])

    return resp_out
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -