Part of my functions is to create pipelines to keep updated information from different sources or streaming