Function watch 

async fn watch(
    node: Node,
    status: NodeStatus,
    db: Database,
    sender: UnboundedSender<EpochInit>,
    _producer_pk: String,
)