Sign up to take part
Registered users can ask their own questions, contribute to discussions, and be part of the Community!
For a scenario, I wish to add a auto trigger where I wish to run it when two particular scenarios are run successfully.
I have a scenario C, which I wish to auto trigger after scenario A and B are both run successfully and not just one of them. Can you please provide me the custom trigger python code to write to achieve this. I am confused
It's possibly to run a scenario from a step in another scenario, so if possible, I recommend modifying scenario C so that it runs scenario A and scenario B as the first steps. For details, please see this post: Run Scenario after multiple scenarios have completed.
If the above doesn't work with your use case, then it is possible to create a custom trigger that triggers only when scenario A and scenario B have both completed successfully.
Here's the code for the trigger. Be sure to replace the scenario IDs at line 24 with your actual scenario IDs.
import sys import dataiku from dataiku.scenario import Trigger def get_last_run_time(scenario): """Get the time that the scenario last completed successfully Returns `None` if the scenario has never completed successfully """ try: last_run = scenario.get_last_successful_run() except ValueError: return None return last_run.start_time t = Trigger() client = dataiku.api_client() project = client.get_default_project() # This scenario scenario = project.get_scenario("SCENARIO_C") # Scenarios that you want to watch watched1 = project.get_scenario("SCENARIO_A") watched2 = project.get_scenario("SCENARIO_B") this_time = get_last_run_time(scenario) watched1_time = get_last_run_time(watched1) watched2_time = get_last_run_time(watched2) if watched1_time is None or watched2_time is None: print("Watched scenarios have never run. Aborting") sys.exit() if this_time is None: print("This scenario has never run. Triggering") t.fire() sys.exit() if watched1_time > this_time and watched2_time > this_time: print("Watched scenarios have both run recently. Triggering") t.fire() else: print("This scenario has run recently. Aborting")