code: def add_cluster(dbstream, initial_point, move_towards, times=1):
      dbstream.learn_one(initial_point)
      for _ in range(times):
          dbstream.learn_one(move_towards)
  
file_path: river/river/cluster/test_dbstream.py
imports: from __future__ import annotations
  import pytest
  from sklearn.datasets import make_blobs
  from river import metrics, stream, utils
  from river.cluster import DBSTREAM
label_desc: Use image node_id 2 for calling a global function with example usage: add_cluster(dbstream, initial_point, move_towards, times) without return types