code: def test_binary_operators(op, getter, stream):
      df = cudf.DataFrame({"x": [1, 2, 3], "y": [4, 5, 6]})
      try:
          left = op(getter(df), 2)
          right = op(2, getter(df))
      except Exception:
          return
  
      a = DataFrame(example=df, stream=stream)
      li = op(getter(a), 2).stream.gather().sink_to_list()
      r = op(2, getter(a)).stream.gather().sink_to_list()
  
      a.emit(df)
  
      assert_eq(li[0], left)
      assert_eq(r[0], right)
  
imports: import json
  import operator
  import numpy
  import pandas
  import pytest
  from dask.dataframe.utils import assert_eq
  from distributed import Client
  from streamz import Stream
  from streamz.dask import DaskStream
  from streamz.dataframe import Aggregation, DataFrame, DataFrames, Series
label_desc: Use image node_id 8 for calling a global function with example usage: test_binary_operators(op, getter, stream) without return types