Skip to content

Instantly share code, notes, and snippets.

@ChasManRors

ChasManRors/gist:74fbd2db6b2c77817d6835406315e325

Created March 24, 2020 21:53
Show Gist options
  • Save ChasManRors/74fbd2db6b2c77817d6835406315e325 to your computer and use it in GitHub Desktop.
Save ChasManRors/74fbd2db6b2c77817d6835406315e325 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
gistfile1.txt
first_name,last_name,phone,van_id
Joleen,Tamsin,205-296-8267,1000
Pen,Sabryna,206-986-8493,648017
Trish,Alyssia,210-270-1802,829734
Paulie,Geneva,215-424-6951,894155
@ChasManRors
Copy link
Author

ChasManRors commented Mar 24, 2020 •
edited
Loading 

18:33:42 worker.1        | From: /Users/charlesmagid/projects/web-app/app/workers/import_contact_list_job.rb @ line 185 ImportContactListJob#perform:
18:33:42 worker.1        |
18:33:42 worker.1        |     175:   def perform(contact_list_id)
18:33:42 worker.1        |     176:
18:33:42 worker.1        |     177:     logger.error "I am in the perform".cyan
18:33:42 worker.1        |     178:
18:33:42 worker.1        |     179: binding.pry
18:33:42 worker.1        |     180:
18:33:42 worker.1        |     181:     return if cancelled?
18:33:42 worker.1        |     182:
18:33:42 worker.1        |     183:     contact_list = ContactList.find(contact_list_id)
18:33:42 worker.1        |     184:
18:33:42 worker.1        |  => 185:     n_created = extract_from_csv(contact_list.media_url, contact_list)
18:33:42 worker.1        |     186:
18:33:42 worker.1        |     187:     if n_created > 0
18:33:42 worker.1        |     188:       puts('Success')
18:33:42 worker.1        |     189:       contact_list.succeed!
18:33:42 worker.1        |     190:     else
18:33:42 worker.1        |     191:       puts('Error')
18:33:42 worker.1        |     192:       contact_list.error!
18:33:42 worker.1        |     193:     end
18:33:42 worker.1        |     194:   rescue StandardError => e
18:33:42 worker.1        |     195:     slackbot_update_error(contact_list.campaign_id)
18:33:42 worker.1        |     196:     contact_list.error!
18:33:42 worker.1        |     197:     Airbrake.notify(e)
18:33:42 worker.1        |     198:     logger.error(message: "contact list parsing failed", exception: e)
18:33:42 worker.1        |     199:   ensure
18:33:42 worker.1        |     200:     # TODO: delete file from S3 after contact_list is created if we own it
18:33:42 worker.1        |     201:     # s3 ||= Aws::S3::Resource.new
18:33:42 worker.1        |     202:     # s3.bucket(ENV.fetch('AWS_S3_BUCKET')).object(csv_aws_key).delete
18:33:42 worker.1        |     203:   end
18:33:42 worker.1        |
18:33:48 worker.1        | [11] pry(#<ImportContactListJob>)> => 8
18:33:53 worker.1        | [12] pry(#<ImportContactListJob>)>
18:33:53 worker.1        | From: /Users/charlesmagid/projects/web-app/app/workers/import_contact_list_job.rb @ line 185 ImportContactListJob#perform:
18:33:53 worker.1        |
18:33:53 worker.1        |     175:   def perform(contact_list_id)
18:33:53 worker.1        |     176:
18:33:53 worker.1        |     177:     logger.error "I am in the perform".cyan
18:33:53 worker.1        |     178:
18:33:53 worker.1        |     179: binding.pry
18:33:53 worker.1        |     180:
18:33:53 worker.1        |     181:     return if cancelled?
18:33:53 worker.1        |     182:
18:33:53 worker.1        |     183:     contact_list = ContactList.find(contact_list_id)
18:33:53 worker.1        |     184:
18:33:53 worker.1        |  => 185:     n_created = extract_from_csv(contact_list.media_url, contact_list)
18:33:53 worker.1        |     186:
18:33:53 worker.1        |     187:     if n_created > 0
18:33:53 worker.1        |     188:       puts('Success')
18:33:53 worker.1        |     189:       contact_list.succeed!
18:33:53 worker.1        |     190:     else
18:33:53 worker.1        |     191:       puts('Error')
18:33:53 worker.1        |     192:       contact_list.error!
18:33:53 worker.1        |     193:     end
18:33:53 worker.1        |     194:   rescue StandardError => e
18:33:53 worker.1        |     195:     slackbot_update_error(contact_list.campaign_id)
18:33:53 worker.1        |     196:     contact_list.error!
18:33:53 worker.1        |     197:     Airbrake.notify(e)
18:33:53 worker.1        |     198:     logger.error(message: "contact list parsing failed", exception: e)
18:33:53 worker.1        |     199:   ensure
18:33:53 worker.1        |     200:     # TODO: delete file from S3 after contact_list is created if we own it
18:33:53 worker.1        |     201:     # s3 ||= Aws::S3::Resource.new
18:33:53 worker.1        |     202:     # s3.bucket(ENV.fetch('AWS_S3_BUCKET')).object(csv_aws_key).delete
18:33:53 worker.1        |     203:   end
18:33:53 worker.1        |
18:33:56 worker.1        | [13] pry(#<ImportContactListJob>)> W, [2020-03-24T18:33:56.418943 #40301]  WARN -- : CustomField: overriding method 'delete'!
18:33:56 worker.1        | W, [2020-03-24T18:33:56.693270 #40301]  WARN -- : Tag: overriding method 'delete'!
18:34:01 web.1           | 2020-03-24 18:34:01.169783 D [40323:puma 001] Rack -- Started -- { :method => "GET", :path => "/api/v2/contact_lists/421/download_fake_csv", :ip => "98.118.4.20" }
18:34:01 web.1           | 2020-03-24 18:34:01.251212 D [40323:puma 001] Api::V2::ContactListsController -- Processing #download_fake_csv
18:34:01 web.1           | 2020-03-24 18:34:01.253530 D [40323:puma 001] (1.583ms) ActiveRecord -- ContactList Load -- { :sql => "SELECT  \"contact_lists\".* FROM \"contact_lists\" WHERE \"contact_lists\".\"id\" = 421 LIMIT 1 /*controller_with_namespace:Api::V2::ContactListsController,action:download_fake_csv,line:/app/controllers/api/v2/contact_lists_controller.rb:109:in `load_for_webhook'*/" }
18:34:01 web.1           | 2020-03-24 18:34:01.254397 I [40323:puma 001] (0.457ms) Rails -- Sent file -- { :path => "/Users/charlesmagid/projects/web-app/public/fake_van_content_list.csv" }
18:34:01 web.1           | 2020-03-24 18:34:01.254712 I [40323:puma 001] (3.320ms) Api::V2::ContactListsController -- Completed #download_fake_csv -- { :controller => "Api::V2::ContactListsController", :action => "download_fake_csv", :params => { "contact_list_id" => "421" }, :format => "*/*", :method => "GET", :path => "/api/v2/contact_lists/421/download_fake_csv", :status => 200, :view_runtime => 0.0, :db_runtime => 1.58, :status_message => "OK" }
18:34:01 web.1           | 2020-03-24 18:34:01.461146 D [40323:puma 001] Rack -- Started -- { :method => "GET", :path => "/api/v2/contact_lists/421/download_fake_csv", :ip => "98.118.4.20" }
18:34:01 web.1           | 2020-03-24 18:34:01.490547 D [40323:puma 001] Api::V2::ContactListsController -- Processing #download_fake_csv
18:34:01 web.1           | 2020-03-24 18:34:01.492892 D [40323:puma 001] (1.656ms) ActiveRecord -- ContactList Load -- { :sql => "SELECT  \"contact_lists\".* FROM \"contact_lists\" WHERE \"contact_lists\".\"id\" = 421 LIMIT 1 /*controller_with_namespace:Api::V2::ContactListsController,action:download_fake_csv,line:/app/controllers/api/v2/contact_lists_controller.rb:109:in `load_for_webhook'*/" }
18:34:01 web.1           | 2020-03-24 18:34:01.493781 I [40323:puma 001] (0.468ms) Rails -- Sent file -- { :path => "/Users/charlesmagid/projects/web-app/public/fake_van_content_list.csv" }
18:34:01 web.1           | 2020-03-24 18:34:01.494154 I [40323:puma 001] (3.438ms) Api::V2::ContactListsController -- Completed #download_fake_csv -- { :controller => "Api::V2::ContactListsController", :action => "download_fake_csv", :params => { "contact_list_id" => "421" }, :format => "*/*", :method => "GET", :path => "/api/v2/contact_lists/421/download_fake_csv", :status => 200, :view_runtime => 0.0, :db_runtime => 1.66, :status_message => "OK" }
18:34:06 worker.1        | Success
18:34:06 worker.1        |
18:34:06 worker.1        | From: /Users/charlesmagid/.rvm/gems/ruby-2.6.5/gems/connection_pool-2.2.2/lib/connection_pool.rb @ line 68 ConnectionPool#with:
18:34:06 worker.1        |
18:34:06 worker.1        |     60: def with(options = {})
18:34:06 worker.1        |     61:   Thread.handle_interrupt(Exception => :never) do
18:34:06 worker.1        |     62:     conn = checkout(options)
18:34:06 worker.1        |     63:     begin
18:34:06 worker.1        |     64:       Thread.handle_interrupt(Exception => :immediate) do
18:34:06 worker.1        |     65:         yield conn
18:34:06 worker.1        |     66:       end
18:34:06 worker.1        |     67:     ensure
18:34:06 worker.1        |  => 68:       checkin
18:34:06 worker.1        |     69:     end
18:34:06 worker.1        |     70:   end
18:34:06 worker.1        |     71: end
18:34:06 worker.1        |
[6] pry(#<ConnectionPool>)> Success
18:34:08 worker.1        |
18:34:08 worker.1        | From: /Users/charlesmagid/.rvm/gems/ruby-2.6.5/gems/connection_pool-2.2.2/lib/connection_pool.rb @ line 68 ConnectionPool#with:
18:34:08 worker.1        |
18:34:08 worker.1        |     60: def with(options = {})
18:34:08 worker.1        |     61:   Thread.handle_interrupt(Exception => :never) do
18:34:08 worker.1        |     62:     conn = checkout(options)
18:34:08 worker.1        |     63:     begin
18:34:08 worker.1        |     64:       Thread.handle_interrupt(Exception => :immediate) do
18:34:08 worker.1        |     65:         yield conn
18:34:08 worker.1        |     66:       end
18:34:08 worker.1        |     67:     ensure
18:34:08 worker.1        |  => 68:       checkin
18:34:08 worker.1        |     69:     end
18:34:08 worker.1        |     70:   end
18:34:08 worker.1        |     71: end
18:34:08 worker.1        |

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment