fix: unified project field during dataloading progress (#4465)

Author: lidongze0629

coordinator/gscoordinator/flex/core/insight/job.py

@@ -39,9 +39,10 @@
 logger = logging.getLogger("graphscope")
 
 class FetchDataloadingJobStatus(object):
-    def __init__(self, graph, status: JobStatus):
+    def __init__(self, graph, status: JobStatus, project=PROJECT):
         self._graph = graph
         self._status = status
+        self._project = project
         self._fetching_thread = StoppableThread(target=self._fetch_impl, args=())
         self._fetching_thread.daemon = True
         self._fetching_thread.start()
@@ -52,7 +53,7 @@ def _fetch_impl(self):
         s = self._status.to_dict()
         conn = http.client.HTTPConnection(STUDIO_WRAPPER_ENDPOINT)
         params = urllib.parse.urlencode(
-            {"jobId": s["id"], "project": PROJECT, "baseId": BASEID}
+            {"jobId": s["id"], "project": self._project, "baseId": BASEID}
         )
         while not self._fetching_thread.stopped():
             try:
@@ -294,13 +295,15 @@ def run(self):
                 location = data_source["inputs"][0]
                 load_from_odps = load_from_odps and location.startswith("odps://")
 
+            project = PROJECT
             if not load_from_odps:
                 status = self.import_data_from_local_file()
             else:
                 # load from odps
                 configini = convert_to_configini(
                     self._graph, self._ds_manager, self._config
                 )
+                project = configini["project"]
                 # conn
                 conn = http.client.HTTPConnection(STUDIO_WRAPPER_ENDPOINT)
                 conn.request(
@@ -337,4 +340,4 @@ def run(self):
             if isinstance(conn, http.client.HTTPConnection):
                 conn.close()
         # register job status
-        self._job_status[self.jobid] = FetchDataloadingJobStatus(self._graph, status)
+        self._job_status[self.jobid] = FetchDataloadingJobStatus(self._graph, status, project)