5
5
from unstructured_client import utils
6
6
from unstructured_client .models import errors , operations , shared
7
7
8
-
9
8
class General :
10
9
sdk_configuration : SDKConfiguration
11
10
12
11
def __init__ (self , sdk_config : SDKConfiguration ) -> None :
13
12
self .sdk_configuration = sdk_config
14
-
15
- def partition (
16
- self ,
17
- request : shared .PartitionParameters ,
18
- retries : Optional [utils .RetryConfig ] = None ,
19
- ) -> operations .PartitionResponse :
13
+
14
+
15
+
16
+ def partition (self , request : shared .PartitionParameters , retries : Optional [utils .RetryConfig ] = None ) -> operations .PartitionResponse :
20
17
r"""Pipeline 1"""
21
18
base_url = utils .template_url (* self .sdk_configuration .get_server_details ())
22
-
23
- url = base_url + " /general/v0/general"
19
+
20
+ url = base_url + ' /general/v0/general'
24
21
headers = {}
25
- req_content_type , data , form = utils .serialize_request_body (
26
- request , "request" , False , True , "multipart"
27
- )
28
- if req_content_type not in ("multipart/form-data" , "multipart/mixed" ):
29
- headers ["content-type" ] = req_content_type
30
- headers ["Accept" ] = "application/json"
31
- headers ["user-agent" ] = self .sdk_configuration .user_agent
32
-
22
+ req_content_type , data , form = utils .serialize_request_body (request , "request" , False , True , 'multipart' )
23
+ if req_content_type not in ('multipart/form-data' , 'multipart/mixed' ):
24
+ headers ['content-type' ] = req_content_type
25
+ headers ['Accept' ] = 'application/json'
26
+ headers ['user-agent' ] = self .sdk_configuration .user_agent
27
+
33
28
if callable (self .sdk_configuration .security ):
34
- client = utils .configure_security_client (
35
- self .sdk_configuration .client , self .sdk_configuration .security ()
36
- )
29
+ client = utils .configure_security_client (self .sdk_configuration .client , self .sdk_configuration .security ())
37
30
else :
38
- client = utils .configure_security_client (
39
- self .sdk_configuration .client , self .sdk_configuration .security
40
- )
41
-
31
+ client = utils .configure_security_client (self .sdk_configuration .client , self .sdk_configuration .security )
32
+
42
33
global_retry_config = self .sdk_configuration .retry_config
43
34
retry_config = retries
44
35
if retry_config is None :
45
36
if global_retry_config :
46
37
retry_config = global_retry_config
47
38
else :
48
- retry_config = utils .RetryConfig (
49
- "backoff" , utils .BackoffStrategy (500 , 60000 , 1.5 , 3600000 ), True
50
- )
39
+ retry_config = utils .RetryConfig ('backoff' , utils .BackoffStrategy (500 , 60000 , 1.5 , 3600000 ), True )
51
40
52
41
def do_request ():
53
- return client .request ("POST" , url , data = data , files = form , headers = headers )
54
-
55
- http_res = utils .retry (do_request , utils .Retries (retry_config , ["5xx" ]))
56
- content_type = http_res .headers .get ("Content-Type" )
42
+ return client .request ('POST' , url , data = data , files = form , headers = headers )
57
43
58
- res = operations .PartitionResponse (
59
- status_code = http_res .status_code ,
60
- content_type = content_type ,
61
- raw_response = http_res ,
62
- )
44
+ http_res = utils .retry (do_request , utils .Retries (retry_config , [
45
+ '5xx'
46
+ ]))
47
+ content_type = http_res .headers .get ('Content-Type' )
63
48
49
+ res = operations .PartitionResponse (status_code = http_res .status_code , content_type = content_type , raw_response = http_res )
50
+
64
51
if http_res .status_code == 200 :
65
- if utils .match_content_type (content_type , " application/json" ):
52
+ if utils .match_content_type (content_type , ' application/json' ):
66
53
out = utils .unmarshal_json (http_res .text , Optional [List [Any ]])
67
54
res .elements = out
68
55
else :
69
- raise errors .SDKError (
70
- f"unknown content-type received: { content_type } " ,
71
- http_res .status_code ,
72
- http_res .text ,
73
- http_res ,
74
- )
56
+ raise errors .SDKError (f'unknown content-type received: { content_type } ' , http_res .status_code , http_res .text , http_res )
75
57
elif http_res .status_code == 422 :
76
- if utils .match_content_type (content_type , " application/json" ):
58
+ if utils .match_content_type (content_type , ' application/json' ):
77
59
out = utils .unmarshal_json (http_res .text , errors .HTTPValidationError )
78
60
out .raw_response = http_res
79
61
raise out
80
62
else :
81
- raise errors .SDKError (
82
- f"unknown content-type received: { content_type } " ,
83
- http_res .status_code ,
84
- http_res .text ,
85
- http_res ,
86
- )
87
- elif (
88
- http_res .status_code >= 400
89
- and http_res .status_code < 500
90
- or http_res .status_code >= 500
91
- and http_res .status_code < 600
92
- ):
93
- raise errors .SDKError (
94
- "API error occurred" , http_res .status_code , http_res .text , http_res
95
- )
63
+ raise errors .SDKError (f'unknown content-type received: { content_type } ' , http_res .status_code , http_res .text , http_res )
64
+ elif http_res .status_code >= 400 and http_res .status_code < 500 or http_res .status_code >= 500 and http_res .status_code < 600 :
65
+ raise errors .SDKError ('API error occurred' , http_res .status_code , http_res .text , http_res )
96
66
97
67
return res
68
+
69
+
0 commit comments