StartImportJob

id: healthlake_start_import
namespace: company.team

inputs:
  - id: datastore_id
    type: STRING
  - id: s3_input_uri
    type: STRING

tasks:
  - id: start_import
    type: io.kestra.plugin.aws.healthlake.StartImportJob
    region: "{{ secret('AWS_REGION') }}"
    accessKeyId: "{{ secret('AWS_ACCESS_KEY_ID') }}"
    secretKeyId: "{{ secret('AWS_SECRET_ACCESS_KEY') }}"
    datastoreId: "{{ inputs.datastore_id }}"
    inputS3Uri: "{{ inputs.s3_input_uri }}"
    outputS3Uri: "s3://my-bucket/healthlake-output/"
    dataAccessRoleArn: "{{ secret('HEALTHLAKE_ROLE_ARN') }}"

  - id: log_job
    type: io.kestra.plugin.core.log.Log
    message: "Import job started: {{ outputs.start_import.jobId }}"