FabricTrigger¶
Trigger for deferrably polling a Microsoft Fabric item run until it terminates.
- class scamander.providers.fabric.triggers.fabric_trigger.FabricTrigger(fabric_conn_id: str, item_run_id: str, workspace_id: str, item_id: str, job_type: str, end_time: float, check_interval: int = 60, wait_for_termination: bool = True, use_notebook_beta_endpoints: bool = False)¶
Basisklassen:
BaseTriggerTrigger when a Fabric item run finishes.
- async run() AsyncIterator[TriggerEvent]¶
Make async connection to the fabric and polls for the item run status.
- serialize()¶
Serialize the FabricTrigger instance.