@apply_defaults<EOL><INDENT>def __init__(<EOL>self,<EOL>job_id,<EOL>json=None,<EOL>notebook_params=None,<EOL>python_params=None,<EOL>spark_submit_params=None,<EOL>databricks_conn_id='<STR_LIT>',<EOL>polling_period_seconds=<NUM_LIT:30>,<EOL>databricks_retry_limit=<NUM_LIT:3>,<EOL>databricks_retry_delay=<NUM_LIT:1>,<EOL>do_xcom_push=False,<EOL>**kwargs):<DEDENT>
super().__init__(**kwargs)<EOL>self.json = json or {}<EOL>self.databricks_conn_id = databricks_conn_id<EOL>self.polling_period_seconds = polling_period_seconds<EOL>self.databricks_retry_limit = databricks_retry_limit<EOL>self.databricks_retry_delay = databricks_retry_delay<EOL>if job_id is not None:<EOL><INDENT>self.json['<STR_LIT>'] = job_id<EOL><DEDENT>if notebook_params is not None:<EOL><INDENT>self.json['<STR_LIT>'] = notebook_params<EOL><DEDENT>if python_params is not None:<EOL><INDENT>self.json['<STR_LIT>'] = python_params<EOL><DEDENT>if spark_submit_params is not None:<EOL><INDENT>self.json['<STR_LIT>'] = spark_submit_params<EOL><DEDENT>self.json = _deep_string_coerce(self.json)<EOL>self.run_id = None<EOL>self.do_xcom_push = do_xcom_push<EOL>
Creates a new ``DatabricksRunNowOperator``.