Skip to content

Instantly share code, notes, and snippets.

Embed
What would you like to do?
worker_1 | 20180625 15:52:42:urllib3.connectionpool:DEBUG http://es:9200 "POST /q4_2016/_doc/_update_by_query HTTP/1.1" 404 351
worker_1 | 20180625 15:52:42:elasticsearch:WARNING POST http://es:9200/q4_2016/_doc/_update_by_query [status:404 request:0.038s]
worker_1 | 20180625 15:52:42:elasticsearch:DEBUG > {"query":{"bool":{"should":[{"exists":{"field":"asked.test-project"}},{"exists":{"field":"test-project"}}],"minimum_should_match":1}},"script":{"source":"\n def fields = new ArrayList(ctx._source.keySet());\n if (params.fresh_sample_fields.containsAll(fields)){\n ctx.op = 'delete';\n } else {\n ctx._source.remove(params.project_id);\n ctx._source.asked.remove(params.project_id);\n }\n ","lang":"painless","params":{"not_exist_project_id":"invalid_project","project_id":"test-project","fresh_sample_fields":["asked","waves","test-project"]}}}
worker_1 | 20180625 15:52:42:elasticsearch:DEBUG < {"error":{"root_cause":[{"type":"index_not_found_exception","reason":"no such index","resource.type":"index_or_alias","resource.id":"q4_2016","index_uuid":"_na_","index":"q4_2016"}],"type":"index_not_found_exception","reason":"no such index","resource.type":"index_or_alias","resource.id":"q4_2016","index_uuid":"_na_","index":"q4_2016"},"status":404}
worker_1 | 20180625 15:52:42:rq.worker:ERROR elasticsearch.exceptions.NotFoundError: TransportError(404, 'index_not_found_exception', 'no such index')
worker_1 | Traceback (most recent call last):
worker_1 | File "/usr/local/lib/python3.6/site-packages/rq/worker.py", line 793, in perform_job
worker_1 | rv = job.perform()
worker_1 | File "/usr/local/lib/python3.6/site-packages/rq/job.py", line 599, in perform
worker_1 | self._result = self._execute()
worker_1 | File "/usr/local/lib/python3.6/site-packages/rq/job.py", line 605, in _execute
worker_1 | return self.func(*self.args, **self.kwargs)
worker_1 | File "/usr/local/lib/python3.6/site-packages/pycrux/notifications.py", line 104, in _notify_callback_inner
worker_1 | return func(*args, **kwargs)
worker_1 | File "/usr/local/lib/python3.6/site-packages/pycrux/logging_.py", line 73, in _log_metrics_inner
worker_1 | return func(*args, **kwargs)
worker_1 | File "/usr/src/app/freight/actions.py", line 80, in delete_project
worker_1 | indexes=indexes).process_indexes()
worker_1 | File "/usr/src/app/freight/data_deleters.py", line 60, in process_indexes
worker_1 | total += self.process_index(index)
worker_1 | File "/usr/src/app/freight/data_deleters.py", line 45, in process_index
worker_1 | total = self._delete_data(index)
worker_1 | File "/usr/src/app/freight/data_deleters.py", line 110, in _delete_data
worker_1 | total = self._delete_project_from_respondent(index)
worker_1 | File "/usr/src/app/freight/data_deleters.py", line 160, in _delete_project_from_respondent
worker_1 | info = self.target_es.update_by_query(index=index.wave, doc_type=self.doc_type, body=body)
worker_1 | File "/usr/local/lib/python3.6/site-packages/elasticsearch/client/utils.py", line 76, in _wrapped
worker_1 | return func(*args, params=params, **kwargs)
worker_1 | File "/usr/local/lib/python3.6/site-packages/elasticsearch/client/__init__.py", line 748, in update_by_query
worker_1 | doc_type, '_update_by_query'), params=params, body=body)
worker_1 | File "/usr/local/lib/python3.6/site-packages/elasticsearch/transport.py", line 314, in perform_request
worker_1 | status, headers_response, data = connection.perform_request(method, url, params, body, headers=headers, ignore=ignore, timeout=timeout)
worker_1 | File "/usr/local/lib/python3.6/site-packages/elasticsearch/connection/http_urllib3.py", line 180, in perform_request
worker_1 | self._raise_error(response.status, raw_data)
worker_1 | File "/usr/local/lib/python3.6/site-packages/elasticsearch/connection/base.py", line 125, in _raise_error
worker_1 | raise HTTP_EXCEPTIONS.get(status_code, TransportError)(status_code, error_message, additional_info)
worker_1 | elasticsearch.exceptions.NotFoundError: TransportError(404, 'index_not_found_exception', 'no such index')
worker_1 | Traceback (most recent call last):
worker_1 | File "/usr/local/lib/python3.6/site-packages/rq/worker.py", line 793, in perform_job
worker_1 | rv = job.perform()
worker_1 | File "/usr/local/lib/python3.6/site-packages/rq/job.py", line 599, in perform
worker_1 | self._result = self._execute()
worker_1 | File "/usr/local/lib/python3.6/site-packages/rq/job.py", line 605, in _execute
worker_1 | return self.func(*self.args, **self.kwargs)
worker_1 | File "/usr/local/lib/python3.6/site-packages/pycrux/notifications.py", line 104, in _notify_callback_inner
worker_1 | return func(*args, **kwargs)
worker_1 | File "/usr/local/lib/python3.6/site-packages/pycrux/logging_.py", line 73, in _log_metrics_inner
worker_1 | return func(*args, **kwargs)
worker_1 | File "/usr/src/app/freight/actions.py", line 80, in delete_project
worker_1 | indexes=indexes).process_indexes()
worker_1 | File "/usr/src/app/freight/data_deleters.py", line 60, in process_indexes
worker_1 | total += self.process_index(index)
worker_1 | File "/usr/src/app/freight/data_deleters.py", line 45, in process_index
worker_1 | total = self._delete_data(index)
worker_1 | File "/usr/src/app/freight/data_deleters.py", line 110, in _delete_data
worker_1 | total = self._delete_project_from_respondent(index)
worker_1 | File "/usr/src/app/freight/data_deleters.py", line 160, in _delete_project_from_respondent
worker_1 | info = self.target_es.update_by_query(index=index.wave, doc_type=self.doc_type, body=body)
worker_1 | File "/usr/local/lib/python3.6/site-packages/elasticsearch/client/utils.py", line 76, in _wrapped
worker_1 | return func(*args, params=params, **kwargs)
worker_1 | File "/usr/local/lib/python3.6/site-packages/elasticsearch/client/__init__.py", line 748, in update_by_query
worker_1 | doc_type, '_update_by_query'), params=params, body=body)
worker_1 | File "/usr/local/lib/python3.6/site-packages/elasticsearch/transport.py", line 314, in perform_request
worker_1 | status, headers_response, data = connection.perform_request(method, url, params, body, headers=headers, ignore=ignore, timeout=timeout)
worker_1 | File "/usr/local/lib/python3.6/site-packages/elasticsearch/connection/http_urllib3.py", line 180, in perform_request
worker_1 | self._raise_error(response.status, raw_data)
worker_1 | File "/usr/local/lib/python3.6/site-packages/elasticsearch/connection/base.py", line 125, in _raise_error
worker_1 | raise HTTP_EXCEPTIONS.get(status_code, TransportError)(status_code, error_message, additional_info)
worker_1 | elasticsearch.exceptions.NotFoundError: TransportError(404, 'index_not_found_exception', 'no such index')
worker_1 | 20180625 15:52:42:rq.worker:DEBUG Invoking exception handler <bound method Worker.move_to_failed_queue of <rq.worker.Worker object at 0x7f67c6f6e8d0>>
worker_1 | 20180625 15:52:42:rq.worker:WARNING Moving job to 'failed' queue
worker_1 | 20180625 15:52:42:rq.worker:DEBUG Sent heartbeat to prevent worker timeout. Next one should arrive within 420 seconds.
worker_1 | 20180625 15:52:42:rq.worker:DEBUG Sent heartbeat to prevent worker timeout. Next one should arrive within 420 seconds.
worker_1 | 20180625 15:52:42:rq.worker:DEBUG *** Listening on development,chronicle...
worker_1 | 20180625 15:52:42:rq.worker:DEBUG Sent heartbeat to prevent worker timeout. Next one should arrive within 420 seconds.
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
You can’t perform that action at this time.