michalslowikowski00 commented on a change in pull request #10304:
URL: https://github.com/apache/airflow/pull/10304#discussion_r476229021
##########
File path: airflow/providers/google/cloud/hooks/dataprep.py
##########
@@ -98,3 +99,24 @@ def get_job_group(self, job_id: int, embed: str,
include_deleted: bool) -> Dict[
response = requests.get(url, headers=self._headers, params=params)
response.raise_for_status()
return response.json()
+
+ @retry(stop=stop_after_attempt(5), wait=wait_exponential(multiplier=1,
max=10))
+ def run_job_group(self, recipe_id: int) -> Dict[str, Any]:
+ """
+ Creates a jobGroup, which launches the specified job as the
authenticated user.
+ This performs the same action as clicking on the Run Job button in the
application.
+
+ :param recipe_id: o run a job, you just specify the recipe identifier
(``wrangledDataset.id``).
+ If the job is successful, all defined outputs are generated,
+ as defined in the output object, publications, and writeSettings
objects associated with the recipe.
+ To identify the ``wrangledDataset Id``, select the recipe icon in the
UI flow view and
+ take the id shown in the URL, e.g. if the URL is /flows/10?recipe=7,
the ``wrangledDataset`` Id is 7.
+ :type recipe_id: int.
+ """
+
+ recipe = {"wrangledDataset": {"id": recipe_id}}
Review comment:
It's done and working.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
