vdk-plugin: json loads correction (#3416)

Author: anitaratansingh

projects/vdk-plugins/vdk-oauth-auth/src/vdk/plugin/oauth/oauth_plugin.py

@@ -80,8 +80,12 @@ def vdk_initialize(self, context: CoreContext) -> None:
         # Scenario: data job running in local does not have oauth creds
         credentials_cache = LocalFolderCredentialsCache()
         credentials = credentials_cache.read_credentials()
-        credentials = json.loads(credentials.replace("'", '"'))
-        self.access_token = credentials.get("access_token")
+        try:
+            creds_json = json.loads(credentials)
+        except json.JSONDecodeError as e:
+            log.error(f"Try VDK login command and then try executing data job.")
+            raise e
+        self.access_token = creds_json.get("access_token")
         self.control_service_rest_api_url = (
             oauth_configuration.control_service_rest_api_url()
         )
@@ -114,10 +118,7 @@ def initialize_job(self, context: JobContext) -> None:
                     # Retrieves details of an existing Data Job by specifying the name of the Data Job. | (Stable)
                     oauth_creds = api_instance.oauth_credentials_get(self.team_name)
                 except Exception as e:
-                    print(
-                        "Exception when calling DataJobsSecretsApi->oauth_credentials_get: %s\n"
-                        % e
-                    )
+                    log.error(f"Exception when fetching oauth credentials: {e}")
                     raise e
             oauth_creds = oauth_creds.to_dict()