EmrEtlRunner: set timeout to 120 seconds (closes #3949)

snowplow · Feb 14, 2019 · eff6c19 · eff6c19
1 parent 2b548de
commit eff6c19
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/3-enrich/emr-etl-runner/lib/snowplow-emr-etl-runner/emr_job.rb b/3-enrich/emr-etl-runner/lib/snowplow-emr-etl-runner/emr_job.rb
@@ -159,6 +159,8 @@ def initialize(debug, staging, enrich, staging_stream_enrich, shred, es, archive
         @jobflow.master_instance_type = config[:aws][:emr][:jobflow][:master_instance_type]
         @jobflow.slave_instance_type  = config[:aws][:emr][:jobflow][:core_instance_type]
 
+        @jobflow.timeout = 120
+
         s3_endpoint = get_s3_endpoint(config[:aws][:s3][:region])
         csbr = config[:aws][:s3][:buckets][:raw]
         csbe = config[:aws][:s3][:buckets][:enriched]