Error BrokenPipeError en celery.bin.base dentro de out.
Tenemos una instancia Ec2 fargate en funcionamiento en AWS, hay un trabajador de celery que se está ejecutando mediante
celery -A app status
Repetidamente estamos obteniendo el siguiente error para esta instancia
BrokenPipeError: [Errno 32] Broken pipe
File “celery”, line 8, in
sys.exit(main())
File “celery/main.py”, line 16, in main
_main()
File “celery/bin/celery.py”, line 322, in main
cmd.execute_from_commandline(argv)
File “celery/bin/celery.py”, line 499, in execute_from_commandline
super(CeleryCommand, self).execute_from_commandline(argv)))
File “celery/bin/base.py”, line 305, in execute_from_commandline
return self.handle_argv(self.prog_name, argv[1:])
File “celery/bin/celery.py”, line 491, in handle_argv
return self.execute(command, argv)
File “celery/bin/celery.py”, line 419, in execute
).run_from_argv(self.prog_name, argv[1:], command=argv[0])
File “celery/bin/base.py”, line 309, in run_from_argv
sys.argv if argv is None else argv, command)
File “celery/bin/base.py”, line 393, in handle_argv
return self(*args, **options)
File “celery/bin/base.py”, line 253, in __call__
ret = self.run(*args, **kwargs)
File “celery/bin/control.py”, line 239, in run
nodecount, text.pluralize(nodecount, ‘node’)))
File “celery/bin/base.py”, line 413, in out
print(s, file=fh or self.stdout)
¿Alguna idea al respecto?
davy.ai
Parece que el error está relacionado con la biblioteca Celery. Parece ser que el trabajador de Celery está teniendo problemas para conectarse a la aplicación, lo que está causando el error “BrokenPipeError”. Es posible que la aplicación no se esté ejecutando correctamente o que el trabajador de Celery no esté configurado correctamente. Sería útil revisar la configuración del trabajador de Celery y de la aplicación para asegurarse de que estén configurados correctamente. Además, puede ser útil revisar los registros de la aplicación y del trabajador de Celery para ver si hay otros errores que podrían estar causando el problema.