diff --git a/input_file.go b/input_file.go
index a74a308..e69abc3 100644
--- a/input_file.go
+++ b/input_file.go
@@ -31,7 +31,10 @@ type S3ReadCloser struct {
 func awsConfig() *aws.Config {
 	region := os.Getenv("AWS_DEFAULT_REGION")
 	if region == "" {
-		region = "us-east-1"
+		region = os.Getenv("AWS_REGION")
+		if region == "" {
+			region = "us-east-1"
+		}
 	}
 
 	config := &aws.Config{Region: aws.String(region)}
@@ -40,6 +43,8 @@ func awsConfig() *aws.Config {
 		config.Endpoint = aws.String(endpoint)
 	}
 
+	config.CredentialsChainVerboseErrors = aws.Bool(true)
+
 	return config
 }
 
diff --git a/output_http.go b/output_http.go
index 3d50fcb..ed74526 100644
--- a/output_http.go
+++ b/output_http.go
@@ -79,11 +79,14 @@ type HTTPOutputConfig struct {
 
 	CompatibilityMode bool
 
+  RequestGroup string
+
 	Debug bool
 
 	TrackResponses bool
 }
 
+
 // HTTPOutput plugin manage pool of workers which send request to replayed server
 // By default workers pool is dynamic and starts with 10 workers
 // You can specify fixed number of workers using `--output-http-workers`
@@ -180,7 +183,7 @@ func (o *HTTPOutput) sessionWorkerMaster() {
 			now := time.Now()
 
 			for id, w := range o.workerSessions {
-				if !w.lastActivity.IsZero() && now.Sub(w.lastActivity) >= 60*time.Second {
+				if !w.lastActivity.IsZero() && now.Sub(w.lastActivity) >= 120*time.Second {
 					w.stop <- true
 					delete(o.workerSessions, id)
 					atomic.AddInt64(&o.activeWorkers, -1)