@@ -26,6 +26,7 @@ type ResourceJobEmailNotifications struct {
2626 OnDurationWarningThresholdExceeded []string `json:"on_duration_warning_threshold_exceeded,omitempty"`
2727 OnFailure []string `json:"on_failure,omitempty"`
2828 OnStart []string `json:"on_start,omitempty"`
29+ OnStreamingBacklogExceeded []string `json:"on_streaming_backlog_exceeded,omitempty"`
2930 OnSuccess []string `json:"on_success,omitempty"`
3031}
3132
@@ -573,6 +574,7 @@ type ResourceJobTaskEmailNotifications struct {
573574 OnDurationWarningThresholdExceeded []string `json:"on_duration_warning_threshold_exceeded,omitempty"`
574575 OnFailure []string `json:"on_failure,omitempty"`
575576 OnStart []string `json:"on_start,omitempty"`
577+ OnStreamingBacklogExceeded []string `json:"on_streaming_backlog_exceeded,omitempty"`
576578 OnSuccess []string `json:"on_success,omitempty"`
577579}
578580
@@ -602,6 +604,7 @@ type ResourceJobTaskForEachTaskTaskEmailNotifications struct {
602604 OnDurationWarningThresholdExceeded []string `json:"on_duration_warning_threshold_exceeded,omitempty"`
603605 OnFailure []string `json:"on_failure,omitempty"`
604606 OnStart []string `json:"on_start,omitempty"`
607+ OnStreamingBacklogExceeded []string `json:"on_streaming_backlog_exceeded,omitempty"`
605608 OnSuccess []string `json:"on_success,omitempty"`
606609}
607610
@@ -943,6 +946,10 @@ type ResourceJobTaskForEachTaskTaskWebhookNotificationsOnStart struct {
943946 Id string `json:"id"`
944947}
945948
949+ type ResourceJobTaskForEachTaskTaskWebhookNotificationsOnStreamingBacklogExceeded struct {
950+ Id string `json:"id"`
951+ }
952+
946953type ResourceJobTaskForEachTaskTaskWebhookNotificationsOnSuccess struct {
947954 Id string `json:"id"`
948955}
@@ -951,6 +958,7 @@ type ResourceJobTaskForEachTaskTaskWebhookNotifications struct {
951958 OnDurationWarningThresholdExceeded []ResourceJobTaskForEachTaskTaskWebhookNotificationsOnDurationWarningThresholdExceeded `json:"on_duration_warning_threshold_exceeded,omitempty"`
952959 OnFailure []ResourceJobTaskForEachTaskTaskWebhookNotificationsOnFailure `json:"on_failure,omitempty"`
953960 OnStart []ResourceJobTaskForEachTaskTaskWebhookNotificationsOnStart `json:"on_start,omitempty"`
961+ OnStreamingBacklogExceeded []ResourceJobTaskForEachTaskTaskWebhookNotificationsOnStreamingBacklogExceeded `json:"on_streaming_backlog_exceeded,omitempty"`
954962 OnSuccess []ResourceJobTaskForEachTaskTaskWebhookNotificationsOnSuccess `json:"on_success,omitempty"`
955963}
956964
@@ -1329,6 +1337,10 @@ type ResourceJobTaskWebhookNotificationsOnStart struct {
13291337 Id string `json:"id"`
13301338}
13311339
1340+ type ResourceJobTaskWebhookNotificationsOnStreamingBacklogExceeded struct {
1341+ Id string `json:"id"`
1342+ }
1343+
13321344type ResourceJobTaskWebhookNotificationsOnSuccess struct {
13331345 Id string `json:"id"`
13341346}
@@ -1337,6 +1349,7 @@ type ResourceJobTaskWebhookNotifications struct {
13371349 OnDurationWarningThresholdExceeded []ResourceJobTaskWebhookNotificationsOnDurationWarningThresholdExceeded `json:"on_duration_warning_threshold_exceeded,omitempty"`
13381350 OnFailure []ResourceJobTaskWebhookNotificationsOnFailure `json:"on_failure,omitempty"`
13391351 OnStart []ResourceJobTaskWebhookNotificationsOnStart `json:"on_start,omitempty"`
1352+ OnStreamingBacklogExceeded []ResourceJobTaskWebhookNotificationsOnStreamingBacklogExceeded `json:"on_streaming_backlog_exceeded,omitempty"`
13401353 OnSuccess []ResourceJobTaskWebhookNotificationsOnSuccess `json:"on_success,omitempty"`
13411354}
13421355
@@ -1378,6 +1391,11 @@ type ResourceJobTriggerFileArrival struct {
13781391 WaitAfterLastChangeSeconds int `json:"wait_after_last_change_seconds,omitempty"`
13791392}
13801393
1394+ type ResourceJobTriggerPeriodic struct {
1395+ Interval int `json:"interval"`
1396+ Unit string `json:"unit"`
1397+ }
1398+
13811399type ResourceJobTriggerTable struct {
13821400 Condition string `json:"condition,omitempty"`
13831401 MinTimeBetweenTriggersSeconds int `json:"min_time_between_triggers_seconds,omitempty"`
@@ -1395,6 +1413,7 @@ type ResourceJobTriggerTableUpdate struct {
13951413type ResourceJobTrigger struct {
13961414 PauseStatus string `json:"pause_status,omitempty"`
13971415 FileArrival * ResourceJobTriggerFileArrival `json:"file_arrival,omitempty"`
1416+ Periodic * ResourceJobTriggerPeriodic `json:"periodic,omitempty"`
13981417 Table * ResourceJobTriggerTable `json:"table,omitempty"`
13991418 TableUpdate * ResourceJobTriggerTableUpdate `json:"table_update,omitempty"`
14001419}
@@ -1411,6 +1430,10 @@ type ResourceJobWebhookNotificationsOnStart struct {
14111430 Id string `json:"id"`
14121431}
14131432
1433+ type ResourceJobWebhookNotificationsOnStreamingBacklogExceeded struct {
1434+ Id string `json:"id"`
1435+ }
1436+
14141437type ResourceJobWebhookNotificationsOnSuccess struct {
14151438 Id string `json:"id"`
14161439}
@@ -1419,6 +1442,7 @@ type ResourceJobWebhookNotifications struct {
14191442 OnDurationWarningThresholdExceeded []ResourceJobWebhookNotificationsOnDurationWarningThresholdExceeded `json:"on_duration_warning_threshold_exceeded,omitempty"`
14201443 OnFailure []ResourceJobWebhookNotificationsOnFailure `json:"on_failure,omitempty"`
14211444 OnStart []ResourceJobWebhookNotificationsOnStart `json:"on_start,omitempty"`
1445+ OnStreamingBacklogExceeded []ResourceJobWebhookNotificationsOnStreamingBacklogExceeded `json:"on_streaming_backlog_exceeded,omitempty"`
14221446 OnSuccess []ResourceJobWebhookNotificationsOnSuccess `json:"on_success,omitempty"`
14231447}
14241448
0 commit comments