class_docstr: Creates (or resets) a Databricks job using the API endpoint.
  
  .. seealso::
      https://docs.databricks.com/api/workspace/jobs/create
      https://docs.databricks.com/api/workspace/jobs/reset
  
  :param json: A JSON object containing API parameters which will be passed
      directly to the ``api/2.1/jobs/create`` endpoint. The other named parameters
      (i.e. ``name``, ``tags``, ``tasks``, etc.) to this operator will
      be merged with this json dictionary if they are provided.
      If there are conflicts during the merge, the named parameters will
      take precedence and override the top level json keys. (templated)
  
      .. seealso::
          For more information about templating see :ref:`concepts:jinja-templating`.
  :param name: An optional name for the job.
  :param tags: A map of tags associated with the job.
  :param tasks: A list of task specifications to be executed by this job.
      Array of objects (JobTaskSettings).
  :param job_clusters: A list of job cluster specifications that can be shared and reused by
      tasks of this job. Array of objects (JobCluster).
  :param email_notifications: Object (JobEmailNotifications).
  :param webhook_notifications: Object (WebhookNotifications).
  :param timeout_seconds: An optional timeout applied to each run of this job.
  :param schedule: Object (CronSchedule).
  :param max_concurrent_runs: An optional maximum allowed number of concurrent runs of the job.
  :param git_source: An optional specification for a remote repository containing the notebooks
      used by this job's notebook tasks. Object (GitSource).
  :param access_control_list: List of permissions to set on the job. Array of object
      (AccessControlRequestForUser) or object (AccessControlRequestForGroup) or object
      (AccessControlRequestForServicePrincipal).
  
      .. seealso::
          This will only be used on create. In order to reset ACL consider using the Databricks
          UI.
  :param databricks_conn_id: Reference to the
      :ref:`Databricks connection <howto/connection:databricks>`. (templated)
  :param polling_period_seconds: Controls the rate which we poll for the result of
      this run. By default the operator will poll every 30 seconds.
  :param databricks_retry_limit: Amount of times retry if the Databricks backend is
      unreachable. Its value must be greater than or equal to 1.
  :param databricks_retry_delay: Number of seconds to wait between retries (it
          might be a floating point number).
  :param databricks_retry_args: An optional dictionary with arguments passed to ``tenacity.Retrying`` class.
class_docstr_tok: ["Creates","(","or","resets",")","a","Databricks","job","using","the","API","endpoint",".","..","seealso",":",":","https",":","\/\/docs.databricks.com\/api\/workspace\/jobs\/create","https",":","\/\/docs.databricks.com\/api\/workspace\/jobs\/reset",":","param","json",":","A","JSON","object","containing","API","parameters","which","will","be","passed","directly","to","the","``","api\/2.1\/jobs\/create","``","endpoint",".","The","other","named","parameters","(","i.e",".","``","name","``",",","``","tags","``",",","``","tasks","``",",","etc",".",")","to","this","operator","will","be","merged","with","this","json","dictionary","if","they","are","provided",".","If","there","are","conflicts","during","the","merge",",","the","named","parameters","will","take","precedence","and","override","the","top","level","json","keys",".","(","templated",")","..","seealso",":",":","For","more","information","about","templating","see",":","ref",":","`","concepts",":","jinja-templating","`",".",":","param","name",":","An","optional","name","for","the","job",".",":","param","tags",":","A","map","of","tags","associated","with","the","job",".",":","param","tasks",":","A","list","of","task","specifications","to","be","executed","by","this","job",".","Array","of","objects","(","JobTaskSettings",")",".",":","param","job_clusters",":","A","list","of","job","cluster","specifications","that","can","be","shared","and","reused","by","tasks","of","this","job",".","Array","of","objects","(","JobCluster",")",".",":","param","email_notifications",":","Object","(","JobEmailNotifications",")",".",":","param","webhook_notifications",":","Object","(","WebhookNotifications",")",".",":","param","timeout_seconds",":","An","optional","timeout","applied","to","each","run","of","this","job",".",":","param","schedule",":","Object","(","CronSchedule",")",".",":","param","max_concurrent_runs",":","An","optional","maximum","allowed","number","of","concurrent","runs","of","the","job",".",":","param","git_source",":","An","optional","specification","for","a","remote","repository","containing","the","notebooks","used","by","this","job","'s","notebook","tasks",".","Object","(","GitSource",")",".",":","param","access_control_list",":","List","of","permissions","to","set","on","the","job",".","Array","of","object","(","AccessControlRequestForUser",")","or","object","(","AccessControlRequestForGroup",")","or","object","(","AccessControlRequestForServicePrincipal",")",".","..","seealso",":",":","This","will","only","be","used","on","create",".","In","order","to","reset","ACL","consider","using","the","Databricks","UI",".",":","param","databricks_conn_id",":","Reference","to","the",":","ref",":","`","Databricks","connection","<","howto\/connection",":","databricks",">","`",".","(","templated",")",":","param","polling_period_seconds",":","Controls","the","rate","which","we","poll","for","the","result","of","this","run",".","By","default","the","operator","will","poll","every","30","seconds",".",":","param","databricks_retry_limit",":","Amount","of","times","retry","if","the","Databricks","backend","is","unreachable",".","Its","value","must","be","greater","than","or","equal","to","1.",":","param","databricks_retry_delay",":","Number","of","seconds","to","wait","between","retries","(","it","might","be","a","floating","point","number",")",".",":","param","databricks_retry_args",":","An","optional","dictionary","with","arguments","passed","to","``","tenacity.Retrying","``","class","."]
docstr: Creates a new ``DatabricksCreateJobsOperator``.
docstr_tok: ["Creates","a","new","``","DatabricksCreateJobsOperator","``","."]
code: def __init__(
      self,
      *,
      json: Any | None = None,
      name: str | None = None,
      tags: dict[str, str] | None = None,
      tasks: list[dict] | None = None,
      job_clusters: list[dict] | None = None,
      email_notifications: dict | None = None,
      webhook_notifications: dict | None = None,
      timeout_seconds: int | None = None,
      schedule: dict | None = None,
      max_concurrent_runs: int | None = None,
      git_source: dict | None = None,
      access_control_list: list[dict] | None = None,
      databricks_conn_id: str = "databricks_default",
      polling_period_seconds: int = 30,
      databricks_retry_limit: int = 3,
      databricks_retry_delay: int = 1,
      databricks_retry_args: dict[Any, Any] | None = None,
      **kwargs,
  ) -> None:
      """Creates a new ``DatabricksCreateJobsOperator``."""
      super().__init__(**kwargs)
      self.json = json or {}
      self.databricks_conn_id = databricks_conn_id
      self.polling_period_seconds = polling_period_seconds
      self.databricks_retry_limit = databricks_retry_limit
      self.databricks_retry_delay = databricks_retry_delay
      self.databricks_retry_args = databricks_retry_args
      if name is not None:
          self.json["name"] = name
      if tags is not None:
          self.json["tags"] = tags
      if tasks is not None:
          self.json["tasks"] = tasks
      if job_clusters is not None:
          self.json["job_clusters"] = job_clusters
      if email_notifications is not None:
          self.json["email_notifications"] = email_notifications
      if webhook_notifications is not None:
          self.json["webhook_notifications"] = webhook_notifications
      if timeout_seconds is not None:
          self.json["timeout_seconds"] = timeout_seconds
      if schedule is not None:
          self.json["schedule"] = schedule
      if max_concurrent_runs is not None:
          self.json["max_concurrent_runs"] = max_concurrent_runs
      if git_source is not None:
          self.json["git_source"] = git_source
      if access_control_list is not None:
          self.json["access_control_list"] = access_control_list
  
      self.json = normalise_json_content(self.json)
  
imports: from __future__ import annotations
  import time
  import warnings
  from functools import cached_property
  from logging import Logger
  from typing import TYPE_CHECKING, Any, Sequence
  from airflow.configuration import conf
  from airflow.exceptions import AirflowException, AirflowProviderDeprecationWarning
  from airflow.models import BaseOperator, BaseOperatorLink, XCom
  from airflow.providers.databricks.hooks.databricks import DatabricksHook, RunState
  from airflow.providers.databricks.triggers.databricks import DatabricksExecutionTrigger
  from airflow.providers.databricks.utils.databricks import normalise_json_content, validate_trigger_event
label_desc: Use image node_id 1 to create a new DatabricksCreateJobsOperator object from inherited base classes: BaseOperator with example: obj = DatabricksCreateJobsOperator()