add error recording into elasticsearch for celery pipeline