```ruby
require "trello" # it is not required by default for some reason

class BeeminderWorker
  include Sidekiq::Worker

  def perform(beeminder_user_id: nil, goal_id: nil)
    if goal_id
      filter = { id: goal_id }
    elsif beeminder_user_id
      filter = { users: { beeminder_user_id: beeminder_user_id } }
    else
      filter = {}
    end


    Goal.where(active: true)
        .joins(:user)
        .joins(:credential)
        .where(filter)
        .order("credentials.provider_name = 'beeminder' ASC")
        .find_each(&method(:safe_sync))
  end

  private

  def safe_sync(goal)
    goal.sync
  rescue => e
    Rollbar.error(e, goal_id: goal.id)
    logger.error e.backtrace
    logger.error e.inspect
    goal.update fail_count: (goal.fail_count + 1)
  end
end
```

Add timeout per goal sync
user
```ruby
require "trello" # it is not required by default for some reason

class BeeminderWorker
  include Sidekiq::Worker

  def perform(beeminder_user_id: nil, goal_id: nil)
    if goal_id
      filter = { id: goal_id }
    elsif beeminder_user_id
      filter = { users: { beeminder_user_id: beeminder_user_id } }
    else
      filter = {}
    end


    Goal.where(active: true)
        .joins(:user)
        .joins(:credential)
        .where(filter)
        .order("credentials.provider_name = 'beeminder' ASC")
        .find_each(&method(:safe_sync))
  end

  private

  def safe_sync(goal)
    Timeout::timeout(60) {
      goal.sync
    }
  rescue => e
    Rollbar.error(e, goal_id: goal.id)
    logger.error e.backtrace
    logger.error e.inspect
    goal.update fail_count: (goal.fail_count + 1)
  end
end
```
assistant