diff --git a/setup.py b/setup.py
index a290a70..970f82d 100644
--- a/setup.py
+++ b/setup.py
@@ -8,7 +8,7 @@
     name="ctm-python-client",
     packages=find_packages(where="src"),
     package_dir={"": "src"},
-    version="2.1.3",
+    version="2.1.4",
     description="Python Workflows for Control-M",
     long_description=long_description,
     long_description_content_type='text/markdown',
diff --git a/src/aapi/integration_factory/connection_profiles.py b/src/aapi/integration_factory/connection_profiles.py
index c38d569..b1358ef 100644
--- a/src/aapi/integration_factory/connection_profiles.py
+++ b/src/aapi/integration_factory/connection_profiles.py
@@ -74,24 +74,24 @@ class ConnectionProfileAzureBackup(ConnectionProfile):
 class ConnectionProfileAwsECS(ConnectionProfile):
 
     _type: str = attrs.field(init=False, default='ConnectionProfile:AWS ECS', metadata={
-                             '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:AWS ECS'})
+        '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:AWS ECS'})
     object_name: str = attrs.field(metadata={'_aapi_name_': True})
     aws_ecs_url: str = attrs.field(kw_only=True, default=None, metadata={
         '_aapi_repr_': 'AWS ECS URL'})
     cloud_watch_url: str = attrs.field(kw_only=True, default=None, metadata={
         '_aapi_repr_': 'Cloud Watch URL'})
     aws_region: str = attrs.field(kw_only=True, default=None, metadata={
-                                  '_aapi_repr_': 'AWS Region'})
+        '_aapi_repr_': 'AWS Region'})
     authentication_method: str = attrs.field(kw_only=True, default=None, metadata={
-                                             '_aapi_repr_': 'Authentication Method'})
+        '_aapi_repr_': 'Authentication Method'})
     aws_access_key: str = attrs.field(kw_only=True, default=None, metadata={
-                                      '_aapi_repr_': 'AWS Access Key'})
+        '_aapi_repr_': 'AWS Access Key'})
     aws_secret: str = attrs.field(kw_only=True, default=None, metadata={
-                                  '_aapi_repr_': 'AWS Secret'})
+        '_aapi_repr_': 'AWS Secret'})
     aws_iam_role: str = attrs.field(kw_only=True, default=None, metadata={
         '_aapi_repr_': 'AWS IAM Role'})
     connection_timeout: str = attrs.field(kw_only=True, default=None, metadata={
-                                          '_aapi_repr_': 'Connection Timeout'})
+        '_aapi_repr_': 'Connection Timeout'})
 
 
 @attrs.define
@@ -421,15 +421,15 @@ class ConnectionProfileGCPBigQuery(ConnectionProfile):
 @attrs.define
 class ConnectionProfileGCPDataFlow(ConnectionProfile):
 
-    _type: str = attrs.field(init=False, default='ConnectionProfile:GCP DataFlow', metadata={
-                             '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:GCP DataFlow'})
+    _type: str = attrs.field(init=False, default='ConnectionProfile:GCP Dataflow', metadata={
+        '_aapi_repr_': 'Type', '_type_aapi_': 'ConnectionProfile:GCP Dataflow'})
     object_name: str = attrs.field(metadata={'_aapi_name_': True})
     identity_type: str = attrs.field(kw_only=True, default=None, metadata={
-                                     '_aapi_repr_': 'Identity Type'})
+        '_aapi_repr_': 'Identity Type'})
     data_flow_url: str = attrs.field(kw_only=True, default=None, metadata={
         '_aapi_repr_': 'DataFlow URL'})
     service_account_key: str = attrs.field(kw_only=True, default=None, metadata={
-                                           '_aapi_repr_': 'Service Account Key'})
+        '_aapi_repr_': 'Service Account Key'})
 
 
 @attrs.define
diff --git a/src/aapi/integration_factory/jobs.py b/src/aapi/integration_factory/jobs.py
index e625e14..ce266b5 100644
--- a/src/aapi/integration_factory/jobs.py
+++ b/src/aapi/integration_factory/jobs.py
@@ -62,38 +62,38 @@ class JobAwsBatch(Job):
 class JobAzureBackup(Job):
 
     _type: str = attrs.field(init=False, default='Job:Azure Backup', metadata={
-                             '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Azure Backup'})
+        '_aapi_repr_': 'Type', '_type_aapi_': 'Job:Azure Backup'})
     object_name: str = attrs.field(metadata={'_aapi_name_': True})
     connection_profile: str = attrs.field(kw_only=True, default=None, metadata={
-                                          '_aapi_repr_': 'ConnectionProfile'})
+        '_aapi_repr_': 'ConnectionProfile'})
     action: str = attrs.field(kw_only=True, default=None, metadata={
-                              '_aapi_repr_': 'Action'})
+        '_aapi_repr_': 'Action'})
     vault_resource_group: str = attrs.field(kw_only=True, default=None, metadata={
-                                            '_aapi_repr_': 'Vault Resource Group'})
+        '_aapi_repr_': 'Vault Resource Group'})
     vault_name: str = attrs.field(kw_only=True, default=None, metadata={
-                                  '_aapi_repr_': 'Vault Name'})
-    v_m_resource_group: str = attrs.field(kw_only=True, default=None, metadata={
-                                          '_aapi_repr_': 'VM Resource Group'})
-    v_m_name: str = attrs.field(kw_only=True, default=None, metadata={
-                                '_aapi_repr_': 'VM Name'})
+        '_aapi_repr_': 'Vault Name'})
+    vm_resource_group: str = attrs.field(kw_only=True, default=None, metadata={
+        '_aapi_repr_': 'VM Resource Group'})
+    vm_name: str = attrs.field(kw_only=True, default=None, metadata={
+        '_aapi_repr_': 'VM Name'})
     policy_name: str = attrs.field(kw_only=True, default=None, metadata={
-                                   '_aapi_repr_': 'Policy Name'})
+        '_aapi_repr_': 'Policy Name'})
     include_or_exclude_disks: str = attrs.field(kw_only=True, default=None, metadata={
-                                                '_aapi_repr_': 'Include or Exclude Disks'})
+        '_aapi_repr_': 'Include Or Exclude Disks'})
     disk_list: str = attrs.field(kw_only=True, default=None, metadata={
-                                 '_abstract_aapi_container_': True})
+        '_abstract_aapi_container_': True})
     restore_to_latest_recovery_point: str = attrs.field(kw_only=True, default=None, metadata={
-                                                        '_aapi_repr_': 'Restore to Latest Recovery Point'})
+        '_aapi_repr_': 'Restore to Latest Recovery Point'})
     recovery_point_name: str = attrs.field(kw_only=True, default=None, metadata={
-                                           '_aapi_repr_': 'Recovery Point Name'})
+        '_aapi_repr_': 'Recovery Point Name'})
     storage_account_name: str = attrs.field(kw_only=True, default=None, metadata={
-                                            '_aapi_repr_': 'Storage Account Name'})
+        '_aapi_repr_': 'Storage Account Name'})
     restore_region: str = attrs.field(kw_only=True, default=None, metadata={
-                                      '_aapi_repr_': 'Restore Region'})
+        '_aapi_repr_': 'Restore Region'})
     status_polling_frequency: str = attrs.field(kw_only=True, default=None, metadata={
-                                                '_aapi_repr_': 'Status Polling Frequency'})
+        '_aapi_repr_': 'Status Polling Frequency'})
     failure_tolerance_: str = attrs.field(kw_only=True, default=None, metadata={
-                                          '_aapi_repr_': 'Failure Tolerance '})
+        '_aapi_repr_': 'Failure Tolerance '})
 
 
 @attrs.define
@@ -561,25 +561,25 @@ class JobGCPBigQuery(Job):
 @attrs.define
 class JobGCPDataFlow(Job):
 
-    _type: str = attrs.field(init=False, default='Job:GCP DataFlow', metadata={
-                             '_aapi_repr_': 'Type', '_type_aapi_': 'Job:GCP DataFlow'})
+    _type: str = attrs.field(init=False, default='Job:GCP Dataflow', metadata={
+        '_aapi_repr_': 'Type', '_type_aapi_': 'Job:GCP Dataflow'})
     object_name: str = attrs.field(metadata={'_aapi_name_': True})
     connection_profile: str = attrs.field(kw_only=True, default=None, metadata={
-                                          '_aapi_repr_': 'ConnectionProfile'})
+        '_aapi_repr_': 'ConnectionProfile'})
     project_id: str = attrs.field(kw_only=True, default=None, metadata={
-                                  '_aapi_repr_': 'Project ID'})
+        '_aapi_repr_': 'Project ID'})
     region: str = attrs.field(kw_only=True, default=None, metadata={
-                              '_aapi_repr_': 'Region'})
+        '_aapi_repr_': 'Region'})
     template_type: str = attrs.field(kw_only=True, default=None, metadata={
-                                     '_aapi_repr_': 'Template Type'})
+        '_aapi_repr_': 'Template Type'})
     template_location_gs_: str = attrs.field(kw_only=True, default=None, metadata={
-                                             '_aapi_repr_': 'Template Location (gs://)'})
+        '_aapi_repr_': 'Template Location (gs://)'})
     parameters__json_format: str = attrs.field(kw_only=True, default=None, metadata={
-                                               '_aapi_repr_': 'Parameters (JSON Format)'})
+        '_aapi_repr_': 'Parameters (JSON Format)'})
     verification_poll_interval_in_seconds: str = attrs.field(kw_only=True, default=None, metadata={
-                                                             '_aapi_repr_': 'Verification Poll Interval (in seconds)'})
+        '_aapi_repr_': 'Verification Poll Interval (in seconds)'})
     log_level: str = attrs.field(kw_only=True, default=None, metadata={
-                                 '_aapi_repr_': 'Log Level'})
+        '_aapi_repr_': 'Log Level'})
 
 
 @attrs.define
@@ -1163,6 +1163,7 @@ class JobAwsAthena(Job):
     no_perm: str = attrs.field(kw_only=True, default=None, metadata={
                                '_aapi_repr_': 'NoPerm'})
 
+
 @attrs.define
 class JobGCPDataprep(Job):
 
diff --git a/src/ctm_python_client/__init__.py b/src/ctm_python_client/__init__.py
index 0243382..777a151 100644
--- a/src/ctm_python_client/__init__.py
+++ b/src/ctm_python_client/__init__.py
@@ -1,2 +1,2 @@
-__version__ = '2.1.3'
+__version__ = '2.1.4'
 __author__ = 'BMC Software'
\ No newline at end of file
diff --git a/tests/test_sanity.py b/tests/test_sanity.py
index 7378d1c..f09f33d 100644
--- a/tests/test_sanity.py
+++ b/tests/test_sanity.py
@@ -2,6 +2,6 @@ def test_version_author():
     import ctm_python_client
 
     assert ctm_python_client.__author__ == 'BMC Software'
-    assert ctm_python_client.__version__ == '2.1.3'
+    assert ctm_python_client.__version__ == '2.1.4'