From 8203141a991f17b5c7723ca71fca3316c3f11da2 Mon Sep 17 00:00:00 2001
From: hcl00521 <A18234173281@163.com>
Date: Wed, 21 Aug 2024 15:58:02 +0800
Subject: [PATCH] fix

---
 aliyun/log/logclient.py                        |  8 ++++++--
 tests/export_examples/export_odps_sink_demo.py | 11 +++++++++--
 2 files changed, 15 insertions(+), 4 deletions(-)

diff --git a/aliyun/log/logclient.py b/aliyun/log/logclient.py
index 245322ec..1cfb9e0a 100644
--- a/aliyun/log/logclient.py
+++ b/aliyun/log/logclient.py
@@ -5157,13 +5157,16 @@ def get_export(self, project_name, job_name):
         (resp, header) = self._send("GET", project_name, None, resource, params, headers)
         return GetExportResponse(header, resp)
 
-    def list_export(self, project_name, offset=0, size=100):
+    def list_export(self, project_name, logstore, offset=0, size=100):
         """ list exports
         Unsuccessful operation will cause an LogException.
 
         :type project_name: string
         :param project_name: the Pqroject name
 
+        :type logstore: string
+        :param logstore: the logstore name
+
         :type offset: int
         :param offset: line offset of return logs
 
@@ -5176,13 +5179,14 @@ def list_export(self, project_name, offset=0, size=100):
         # need to use extended method to get more
         if int(size) == -1 or int(size) > MAX_LIST_PAGING_SIZE:
             return list_more(self.list_export, int(offset), int(size), MAX_LIST_PAGING_SIZE,
-                             project_name)
+                             project_name, logstore)
         headers = {}
         params = {}
         resource = '/jobs'
         params['offset'] = str(offset)
         params['size'] = str(size)
         params['jobType'] = "Export"
+        params['logstore'] = logstore
         (resp, header) = self._send("GET", project_name, None, resource, params, headers)
         return ListExportResponse(resp, header)
 
diff --git a/tests/export_examples/export_odps_sink_demo.py b/tests/export_examples/export_odps_sink_demo.py
index f9ff7673..5d1ec9fe 100644
--- a/tests/export_examples/export_odps_sink_demo.py
+++ b/tests/export_examples/export_odps_sink_demo.py
@@ -45,13 +45,20 @@ def update_export():
     jobName = '11111'
     config = getJobConfig(client, project, jobName)  # 获取任务的配置
     config['displayName'] = config['displayName'] + 'new'
-    config['configuration']['sink']['delaySeconds'] = 909
     export = json.dumps(config)
     client.update_export(project_name=project, job_name=jobName, export=export)
 
 
+def list_export():
+    client = LogClient("region", "ak", "ak_key")
+    project = '11111'
+    logstore = '11111'
+    res = client.list_export(project, logstore)
+    res.log_print()
+
+
 def main():
-    update_export()
+    list_export()
 
 
 if __name__ == "__main__":