|
76 | 76 | "NotSupportedError", |
77 | 77 | "OperationError", |
78 | 78 | "IncomparableException", |
79 | | - "Service" |
| 79 | + "Service", |
| 80 | + "namespace" |
80 | 81 | ] |
81 | 82 |
|
82 | 83 | PATH_APPS = "apps/local/" |
@@ -2423,6 +2424,7 @@ def events(self, **kwargs): |
2423 | 2424 |
|
2424 | 2425 | :return: The ``InputStream`` IO handle to this job's events. |
2425 | 2426 | """ |
| 2427 | + kwargs['segmentation'] = kwargs.get('segmentation', 'none') |
2426 | 2428 | return self.get("events", **kwargs).body |
2427 | 2429 |
|
2428 | 2430 | def finalize(self): |
@@ -2508,6 +2510,7 @@ def results(self, **query_params): |
2508 | 2510 |
|
2509 | 2511 | :return: The ``InputStream`` IO handle to this job's results. |
2510 | 2512 | """ |
| 2513 | + query_params['segmentation'] = query_params.get('segmentation', 'none') |
2511 | 2514 | return self.get("results", **query_params).body |
2512 | 2515 |
|
2513 | 2516 | def preview(self, **query_params): |
@@ -2550,6 +2553,7 @@ def preview(self, **query_params): |
2550 | 2553 |
|
2551 | 2554 | :return: The ``InputStream`` IO handle to this job's preview results. |
2552 | 2555 | """ |
| 2556 | + query_params['segmentation'] = query_params.get('segmentation', 'none') |
2553 | 2557 | return self.get("results_preview", **query_params).body |
2554 | 2558 |
|
2555 | 2559 | def searchlog(self, **kwargs): |
@@ -2717,7 +2721,10 @@ def export(self, query, **params): |
2717 | 2721 | """ |
2718 | 2722 | if "exec_mode" in params: |
2719 | 2723 | raise TypeError("Cannot specify an exec_mode to export.") |
2720 | | - return self.post(path_segment="export", search=query, **params).body |
| 2724 | + params['segmentation'] = params.get('segmentation', 'none') |
| 2725 | + return self.post(path_segment="export", |
| 2726 | + search=query, |
| 2727 | + **params).body |
2721 | 2728 |
|
2722 | 2729 | def itemmeta(self): |
2723 | 2730 | """There is no metadata available for class:``Jobs``. |
@@ -2777,7 +2784,10 @@ def oneshot(self, query, **params): |
2777 | 2784 | """ |
2778 | 2785 | if "exec_mode" in params: |
2779 | 2786 | raise TypeError("Cannot specify an exec_mode to oneshot.") |
2780 | | - return self.post(search=query, exec_mode="oneshot", **params).body |
| 2787 | + params['segmentation'] = params.get('segmentation', 'none') |
| 2788 | + return self.post(search=query, |
| 2789 | + exec_mode="oneshot", |
| 2790 | + **params).body |
2781 | 2791 |
|
2782 | 2792 |
|
2783 | 2793 | class Loggers(Collection): |
|
0 commit comments