Skip to content

Commit 36aa59d

Browse files
jimrightjimright
authored
Gracefully handle df errors when Dataflow not enabled on CDP tenant (#45)
* Gracefully handle df errors when Dataflow not enabled on CDP tenant Signed-off-by: Jim Enright <[email protected]>
1 parent d5dd113 commit 36aa59d

File tree

1 file changed

+32
-10
lines changed

1 file changed

+32
-10
lines changed

‎src/cdpy/df.py‎

Lines changed: 32 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,9 @@ def list_services(self, only_enabled=False, env_crn=None, df_crn=None, name=None
1313
result = self.sdk.call(
1414
svc='df', func='list_services', ret_field='services', squelch=[
1515
Squelch(value='NOT_FOUND', default=list(),
16-
warning='No DataFlow Services found')
16+
warning='No DataFlow Services found'),
17+
Squelch(value='PATH_DISABLED', default=list(),
18+
warning='DataFlow not enabled on CDP Tenant')
1719
],
1820
pageSize=self.sdk.DEFAULT_PAGE_SIZE
1921
)
@@ -48,6 +50,8 @@ def describe_service(self, df_crn: str = None, env_crn: str = None):
4850
svc='df', func='describe_service', ret_field='service', squelch=[
4951
Squelch(value='NOT_FOUND',
5052
warning='No DataFlow Service with crn %s found' % df_crn),
53+
Squelch(value='PATH_DISABLED',
54+
warning='DataFlow not enabled on CDP Tenant'),
5155
Squelch(value='PERMISSION_DENIED') # DF GRPC sometimes returns 403 when finishing deletion
5256
],
5357
serviceCrn=resolved_df_crn
@@ -96,7 +100,9 @@ def list_deployments(self, env_crn=None, df_crn=None, name=None, dep_crn=None, d
96100
result = self.sdk.call(
97101
svc='df', func='list_deployments', ret_field='deployments', squelch=[
98102
Squelch(value='NOT_FOUND', default=list(),
99-
warning='No DataFlow Deployments found')
103+
warning='No DataFlow Deployments found'),
104+
Squelch(value='PATH_DISABLED', default=list(),
105+
warning='DataFlow not enabled on CDP Tenant')
100106
],
101107
pageSize=self.sdk.DEFAULT_PAGE_SIZE
102108
)
@@ -135,7 +141,9 @@ def describe_deployment(self, dep_crn=None, df_crn=None, name=None):
135141
return self.sdk.call(
136142
svc='df', func='describe_deployment', ret_field='deployment', squelch=[
137143
Squelch(value='NOT_FOUND',
138-
warning='No DataFlow Deployment with crn %s found' % dep_crn)
144+
warning='No DataFlow Deployment with crn %s found' % dep_crn),
145+
Squelch(value='PATH_DISABLED',
146+
warning='DataFlow not enabled on CDP Tenant')
139147
],
140148
deploymentCrn=dep_crn
141149
)
@@ -145,7 +153,9 @@ def list_readyflows(self, name=None):
145153
result = self.sdk.call(
146154
svc='df', func='list_readyflows', ret_field='readyflows', squelch=[
147155
Squelch(value='NOT_FOUND',
148-
warning='No ReadyFlows found within your CDP Tenant')
156+
warning='No ReadyFlows found within your CDP Tenant'),
157+
Squelch(value='PATH_DISABLED',
158+
warning='DataFlow not enabled on CDP Tenant')
149159
],
150160
)
151161
if name is not None:
@@ -157,7 +167,9 @@ def list_flow_definitions(self, name=None):
157167
result = self.sdk.call(
158168
svc='df', func='list_flow_definitions', ret_field='flows', squelch=[
159169
Squelch(value='NOT_FOUND',
160-
warning='No Flow Definitions found within your CDP Tenant Catalog')
170+
warning='No Flow Definitions found within your CDP Tenant Catalog'),
171+
Squelch(value='PATH_DISABLED',
172+
warning='DataFlow not enabled on CDP Tenant')
161173
],
162174
)
163175
if name is not None:
@@ -170,7 +182,9 @@ def describe_readyflow(self, def_crn):
170182
return self.sdk.call(
171183
svc='df', func='describe_readyflow', ret_field='readyflowDetail', squelch=[
172184
Squelch(value='NOT_FOUND',
173-
warning='No ReadyFlow Definition with crn %s found' % def_crn)
185+
warning='No ReadyFlow Definition with crn %s found' % def_crn),
186+
Squelch(value='PATH_DISABLED',
187+
warning='DataFlow not enabled on CDP Tenant')
174188
],
175189
readyflowCrn=def_crn
176190
)
@@ -181,7 +195,9 @@ def import_readyflow(self, def_crn):
181195
return self.sdk.call(
182196
svc='df', func='add_readyflow', ret_field='addedReadyflowDetail', squelch=[
183197
Squelch(value='NOT_FOUND',
184-
warning='No ReadyFlow Definition with crn %s found' % def_crn)
198+
warning='No ReadyFlow Definition with crn %s found' % def_crn),
199+
Squelch(value='PATH_DISABLED',
200+
warning='DataFlow not enabled on CDP Tenant')
185201
],
186202
readyflowCrn=def_crn
187203
)
@@ -192,7 +208,9 @@ def delete_added_readyflow(self, def_crn):
192208
return self.sdk.call(
193209
svc='df', func='delete_added_readyflow', ret_field='readyflowDetail', squelch=[
194210
Squelch(value='NOT_FOUND',
195-
warning='No ReadyFlow Definition with crn %s found' % def_crn)
211+
warning='No ReadyFlow Definition with crn %s found' % def_crn),
212+
Squelch(value='PATH_DISABLED',
213+
warning='DataFlow not enabled on CDP Tenant')
196214
],
197215
readyflowCrn=def_crn
198216
)
@@ -203,7 +221,9 @@ def describe_added_readyflow(self, def_crn, sort_versions=True):
203221
result = self.sdk.call(
204222
svc='df', func='describe_added_readyflow', ret_field='addedReadyflowDetail', squelch=[
205223
Squelch(value='NOT_FOUND',
206-
warning='No ReadyFlow Definition with crn %s found' % def_crn)
224+
warning='No ReadyFlow Definition with crn %s found' % def_crn),
225+
Squelch(value='PATH_DISABLED',
226+
warning='DataFlow not enabled on CDP Tenant')
207227
],
208228
readyflowCrn=def_crn
209229
)
@@ -219,7 +239,9 @@ def describe_customflow(self, def_crn, sort_versions=True):
219239
result = self.sdk.call(
220240
svc='df', func='describe_flow', ret_field='flowDetail', squelch=[
221241
Squelch(value='NOT_FOUND',
222-
warning='No Flow Definition with crn %s found' % def_crn)
242+
warning='No Flow Definition with crn %s found' % def_crn),
243+
Squelch(value='PATH_DISABLED',
244+
warning='DataFlow not enabled on CDP Tenant')
223245
],
224246
flowCrn=def_crn
225247
)

0 commit comments

Comments
 (0)