self.idle_jobs

in lib/core/connector_job.rb [48:65]

• 17 lines of code
• 2 McCabe index (conditional complexity)

    def self.idle_jobs(connector_id = nil, page_size = DEFAULT_PAGE_SIZE)
      connector_ids = if connector_id
                        [connector_id]
                      else
                        ConnectorSettings.fetch_native_connectors.map(&:id)
                      end
      query = {
        bool: {
          filter: [
              { terms: { 'connector.id': connector_ids } },
              { terms: { status: Connectors::SyncStatus::ACTIVE_STATUSES } },
              { range: { last_seen: { lte: "now-#{IDLE_THRESHOLD}s" } } }
          ]
        }
      }
      fetch_jobs_by_query(query, page_size)
    end