class_docstr: Interface for back pressure policies.
docstr: Determine if we can add a new input to the operator. If returns False, the
  operator will be backpressured and will not be able to run new tasks.
  Used in `streaming_executor_state.py::select_operator_to_run()`.
  
  Returns: True if we can add a new input to the operator, False otherwise.
  
  Note, if multiple backpressure policies are enabled, the operator will be
  backpressured if any of the policies returns False.
docstr_tok: ["Determine","if","we","can","add","a","new","input","to","the","operator",".","If","returns","False",",","the","operator","will","be","backpressured","and","will","not","be","able","to","run","new","tasks",".","Used","in","`","streaming_executor_state.py",":",":select_operator_to_run","(",")","`",".","Returns",":","True","if","we","can","add","a","new","input","to","the","operator",",","False","otherwise",".","Note",",","if","multiple","backpressure","policies","are","enabled",",","the","operator","will","be","backpressured","if","any","of","the","policies","returns","False","."]
code: def can_add_input(self, op: "PhysicalOperator") -> bool:
      """Determine if we can add a new input to the operator. If returns False, the
      operator will be backpressured and will not be able to run new tasks.
      Used in `streaming_executor_state.py::select_operator_to_run()`.
  
      Returns: True if we can add a new input to the operator, False otherwise.
  
      Note, if multiple backpressure policies are enabled, the operator will be
      backpressured if any of the policies returns False.
      """
      return True
  
imports: from abc import ABC, abstractmethod
  from typing import TYPE_CHECKING, Dict
label_desc: Use image node_id 3 for calling the BackpressurePolicy obj's underlying member method code with example usage: obj.can_add_input(op) and returns: True