commune-ai commited on
Commit
f3de0a1
1 Parent(s): e5a438f

Create app.py

Browse files
Files changed (1) hide show
  1. app.py +234 -0
app.py ADDED
@@ -0,0 +1,234 @@
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1
+ import gradio as gr
2
+ from requests.exceptions import ConnectTimeout
3
+ import time
4
+ import requests
5
+ import base64
6
+
7
+ global headers
8
+ global cancel_url
9
+ global path
10
+ global output_image
11
+ global property_name_array
12
+ property_name_array =[]
13
+ output_image = ''
14
+ path = ''
15
+ cancel_url =''
16
+ headers = {
17
+ 'Content-Type': 'application/json',
18
+ 'Authorization': 'Token r8_ZGZlzThfRkPZVDMygVclY1XZ9AuxmIQ2qwwPP',
19
+ "Access-Control-Allow-Headers": "Content-Type",
20
+ "Access-Control-Allow-Origin": '**',
21
+ "Access-Control-Allow-Methods": "OPTIONS,POST,GET,PATCH"}
22
+
23
+ with gr.Blocks() as demo:
24
+ owner = "nightmareai"
25
+ name = "disco-diffusion"
26
+ max_retries = 3
27
+ retry_delay = 2
28
+ for retry in range(max_retries):
29
+ try:
30
+ url = f'https://api.replicate.com/v1/models/{owner}/{name}'
31
+ response = requests.get(url, headers=headers, timeout=10)
32
+ # Process the response
33
+ break # Break out of the loop if the request is successful
34
+ except ConnectTimeout:
35
+ if retry < max_retries - 1:
36
+ print(f"Connection timed out. Retrying in {retry_delay} seconds...")
37
+ time.sleep(retry_delay)
38
+ else:
39
+ print("Max retries exceeded. Unable to establish connection.")
40
+
41
+ data = response.json()
42
+ description =data.get("description", '')
43
+ title = data.get("default_example",'').get("model",'')
44
+ version = data.get("default_example",'').get("version",'')
45
+
46
+ gr.Markdown(
47
+ f"""
48
+ # {title}
49
+ {description}
50
+ """)
51
+
52
+ with gr.Row():
53
+ with gr.Column():
54
+ inputs =[]
55
+ schema = data.get("latest_version", {}).get("openapi_schema", {}).get("components", {}).get("schemas", {})
56
+ ordered_properties = sorted(schema.get("Input", {}).get("properties", {}).items(), key=lambda x: x[1].get("x-order", 0))
57
+ required = schema.get("Input", '').get('required', [])
58
+ print(required,"required")
59
+ for property_name, property_info in ordered_properties :
60
+ property_name_array.append(property_name)
61
+ if required:
62
+ for item in required:
63
+ if item == property_name:
64
+ label = "*"+ property_info.get('title', '')
65
+ description = property_info.get('description','')
66
+ break
67
+ else:
68
+ label = property_info.get('title', '')
69
+ description = property_info.get('description','')
70
+ else:
71
+ label = property_info.get('title', '')
72
+ description = property_info.get('description','')
73
+
74
+ if "x-order" in property_info:
75
+ order = int(property_info.get('x-order',''))
76
+ if property_info.get("type", {}) == "integer":
77
+ value= data.get('default_example', '').get('input','').get(property_name,0)
78
+ if "minimum" and "maximum" in property_info:
79
+ if value == 0:
80
+ inputs.insert(order, gr.Slider(label=label, info= description, value=property_info.get('default', value), minimum=property_info.get('minimum', ''), maximum=property_info.get('maximum', ''), step=1))
81
+ else:
82
+ inputs.insert(order, gr.Slider(label=label, info= description, value=value, minimum=property_info.get('minimum', ''), maximum=property_info.get('maximum', ''), step=1))
83
+ else:
84
+ if value == 0:
85
+ inputs.insert(order, gr.Number(label=label, info= description, value=property_info.get('default', value)))
86
+ else:
87
+ inputs.insert(order, gr.Number(label=label, info= description, value=value))
88
+
89
+ elif property_info.get("type", {}) == "string":
90
+ value= data.get('default_example', '').get('input','').get(property_name,'')
91
+ if property_info.get('format','') == 'uri':
92
+
93
+ if value :
94
+ inputs.insert(order, gr.Image(label=label, value=value))
95
+ else :
96
+ inputs.insert(order, gr.Image(label=label))
97
+
98
+ else:
99
+ if value == '':
100
+ inputs.insert(order, gr.Textbox(label=label,info= description, value=property_info.get('default', value)))
101
+ else:
102
+ inputs.insert(order, gr.Textbox(label=label,info= description, value=value))
103
+
104
+ elif property_info.get("type", {}) == "number":
105
+ value= data.get('default_example', '').get('input','').get(property_name, 0)
106
+ if "minimum" and "maximum" in property_info:
107
+ if value == 0:
108
+ inputs.insert(order, gr.Slider(label=label,info= description, value=property_info.get('default', value), minimum=property_info.get('minimum', ''), maximum=property_info.get('maximum', '')))
109
+ else:
110
+ inputs.insert(order, gr.Slider(label=label,info= description, value=value, minimum=property_info.get('minimum', ''), maximum=property_info.get('maximum', '')))
111
+ else:
112
+ if value == 0:
113
+ inputs.insert(order, gr.Number(label=label,info= description, value=property_info.get('default', value)))
114
+ else:
115
+ inputs.insert(order, gr.Number(label=label,info= description, value=value))
116
+ elif property_info.get("type", {}) == "boolean":
117
+ value= data.get('default_example', '').get('input','').get(property_name,'')
118
+ if value == '':
119
+ inputs.insert(order, gr.Checkbox(label=label,info= description, value=property_info.get('default', value)))
120
+ else:
121
+ inputs.insert(order, gr.Checkbox(label=label,info= description, value=value))
122
+ else:
123
+ value= data.get('default_example', '').get('input','').get(property_name,'')
124
+ options=schema.get(property_name,'').get('enum',[])
125
+ if value == '':
126
+ inputs.insert(order, gr.Dropdown(label=property_name,info= description,choices=options, value=property_info.get("default", value)))
127
+ else:
128
+ inputs.insert(order, gr.Dropdown(label=property_name,info= description,choices=options, value=value))
129
+
130
+ with gr.Row():
131
+ cancel_btn = gr.Button("Cancel")
132
+ run_btn = gr.Button("Run")
133
+
134
+ with gr.Column():
135
+
136
+ outputs = []
137
+
138
+ output_result = data.get("default_example", '').get("output")
139
+ output_type= schema.get("Output", '').get("type", '')
140
+ if output_type == 'array':
141
+ output_image = output_result[-1]
142
+ else:
143
+ output_image = output_result
144
+ print(output_image,'112121')
145
+ outputs.append(gr.Image(value=output_image))
146
+
147
+
148
+
149
+
150
+ def run_process(input1, input2, input3, input4, input5, input6, input7, input8, input9, input10, input11, input12, input13, input14,input15, input16, input17, input18, input19, input20, input21, input22, input23, input24, input25, input26, input27, input28,
151
+ input29, input30, input31, input32, input33, input34, input35, input36, input37, input38, input39, input40, input41, input42, input43):
152
+ global cancel_url
153
+ global property_name_array
154
+ print(len(property_name_array))
155
+ cancel_url=''
156
+ url = 'https://replicate.com/api/predictions'
157
+
158
+ body = {
159
+ "version": version,
160
+ "input": {
161
+ property_name_array[0]: input1,
162
+ property_name_array[1]: input2,
163
+ property_name_array[2]: input2,
164
+ property_name_array[3]: input4,
165
+ property_name_array[4]: input5,
166
+ property_name_array[5]: input6,
167
+ property_name_array[6]: input7,
168
+ property_name_array[7]: input8,
169
+ property_name_array[8]: input9,
170
+ property_name_array[9]: input10,
171
+ property_name_array[10]: input11,
172
+ property_name_array[11]: input12,
173
+ property_name_array[12]: input13,
174
+ property_name_array[13]: input14,
175
+
176
+
177
+ }
178
+ }
179
+
180
+ response = requests.post(url, json=body)
181
+ print(response.status_code)
182
+ if response.status_code == 201:
183
+ response_data = response.json()
184
+ get_url = response_data.get('urls','').get('get','')
185
+ identifier = 'https://replicate.com/api/predictions/'+get_url.split("/")[-1]
186
+
187
+ print(identifier,'')
188
+ time.sleep(3)
189
+ output =verify_image(identifier)
190
+ print(output,'333')
191
+ if output:
192
+ return gr.Image(value=output[-1])
193
+
194
+ return gr.Image()
195
+
196
+ def cancel_process(input1, input2, input3, input4, input5, input6, input7, input8, input9, input10, input11, input12, input13, input14,input15, input16, input17, input18, input19, input20, input21, input22, input23, input24, input25, input26, input27, input28,
197
+ input29, input30, input31, input32, input33, input34, input35, input36, input37, input38, input39, input40, input41, input42, input43):
198
+ global cancel_url
199
+ cancel_url = '123'
200
+ global output_image
201
+ return gr.Image(value=output_image)
202
+
203
+ def verify_image(get_url):
204
+ res = requests.get(get_url)
205
+ if res.status_code == 200:
206
+ res_data = res.json()
207
+ if res_data.get('error',''):
208
+ return
209
+ else:
210
+ if cancel_url:
211
+ return
212
+ else:
213
+ output = res_data.get('output', [])
214
+ print(output,'111')
215
+ if output:
216
+ print(output,'222')
217
+ return output
218
+
219
+ else:
220
+ time.sleep(1)
221
+ val = verify_image(get_url)
222
+ return val
223
+ else:
224
+ return []
225
+
226
+ run_btn.click(run_process, inputs=inputs, outputs=outputs, api_name="run")
227
+ cancel_btn.click(cancel_process, inputs=inputs, outputs=outputs, api_name="cancel")
228
+
229
+ demo.launch()
230
+
231
+
232
+
233
+
234
+