ark-demo/pipelines/nfhl/main.py [7:27]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    inputFile = 'gs://' + str(data['bucket']) + '/' + str(data['name'])
    parameters = {
       'gcs_url': inputFile
    }
    environment = {'temp_location': 'gs://gsd-pipeline-temp'}

    service = build('dataflow', 'v1b3', cache_discovery=False)

    request = service.projects().locations().flexTemplates().launch(
        projectId=project,
        location='us-central1',
        body={
            'launchParameter': {
                'jobName': job,
                'parameters': parameters,
                'environment': environment,
                'containerSpecGcsPath': template
            }
        }
    )
    response = request.execute()
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



ark-demo/pipelines/nhc_forecast/main.py [7:27]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    inputFile = 'gs://' + str(data['bucket']) + '/' + str(data['name'])
    parameters = {
        'gcs_url': inputFile
    }
    environment = {'temp_location': 'gs://gsd-pipeline-temp'}

    service = build('dataflow', 'v1b3', cache_discovery=False)

    request = service.projects().locations().flexTemplates().launch(
        projectId=project,
        location='us-central1',
        body={
            'launchParameter': {
                'jobName': job,
                'parameters': parameters,
                'environment': environment,
                'containerSpecGcsPath': template
            }
        }
    )
    response = request.execute()
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -