Josh Greenhalgh
03/16/2021, 11:10 PMFailed to set task state with error: ConnectionError(MaxRetryError("HTTPConnectionPool(host='34.105.133.228', port=4200): Max retries exceeded with url: /graphql/graphql (Caused by NewConnectionError('<urllib3.connection.HTTPConnection object at 0x7fd4b2539df0>: Failed to establish a new connection: [Errno 104] Connection reset by peer'))"))
Traceback (most recent call last):
File "/usr/local/lib/python3.8/site-packages/urllib3/connection.py", line 169, in _new_conn
conn = connection.create_connection(
File "/usr/local/lib/python3.8/site-packages/urllib3/util/connection.py", line 96, in create_connection
raise err
File "/usr/local/lib/python3.8/site-packages/urllib3/util/connection.py", line 86, in create_connection
sock.connect(sa)
ConnectionResetError: [Errno 104] Connection reset by peer
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.8/site-packages/urllib3/connectionpool.py", line 699, in urlopen
httplib_response = self._make_request(
File "/usr/local/lib/python3.8/site-packages/urllib3/connectionpool.py", line 394, in _make_request
conn.request(method, url, **httplib_request_kw)
File "/usr/local/lib/python3.8/site-packages/urllib3/connection.py", line 234, in request
super(HTTPConnection, self).request(method, url, body=body, headers=headers)
File "/usr/local/lib/python3.8/http/client.py", line 1255, in request
self._send_request(method, url, body, headers, encode_chunked)
File "/usr/local/lib/python3.8/http/client.py", line 1301, in _send_request
self.endheaders(body, encode_chunked=encode_chunked)
File "/usr/local/lib/python3.8/http/client.py", line 1250, in endheaders
self._send_output(message_body, encode_chunked=encode_chunked)
File "/usr/local/lib/python3.8/http/client.py", line 1010, in _send_output
self.send(msg)
File "/usr/local/lib/python3.8/http/client.py", line 950, in send
self.connect()
File "/usr/local/lib/python3.8/site-packages/urllib3/connection.py", line 200, in connect
conn = self._new_conn()
File "/usr/local/lib/python3.8/site-packages/urllib3/connection.py", line 181, in _new_conn
raise NewConnectionError(
urllib3.exceptions.NewConnectionError: <urllib3.connection.HTTPConnection object at 0x7fd4b2539df0>: Failed to establish a new connection: [Errno 104] Connection reset by peer
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.8/site-packages/requests/adapters.py", line 439, in send
resp = conn.urlopen(
File "/usr/local/lib/python3.8/site-packages/urllib3/connectionpool.py", line 755, in urlopen
retries = retries.increment(
File "/usr/local/lib/python3.8/site-packages/urllib3/util/retry.py", line 573, in increment
raise MaxRetryError(_pool, url, error or ResponseError(cause))
urllib3.exceptions.MaxRetryError: HTTPConnectionPool(host='34.105.133.228', port=4200): Max retries exceeded with url: /graphql/graphql (Caused by NewConnectionError('<urllib3.connection.HTTPConnection object at 0x7fd4b2539df0>: Failed to establish a new connection: [Errno 104] Connection reset by peer'))
During handling of the above exception, another exception occurred:
Traceback (most recent call last):
File "/usr/local/lib/python3.8/site-packages/prefect/engine/cloud/task_runner.py", line 98, in call_runner_target_handlers
state = self.client.set_task_run_state(
File "/usr/local/lib/python3.8/site-packages/prefect/client/client.py", line 1518, in set_task_run_state
result = self.graphql(
File "/usr/local/lib/python3.8/site-packages/prefect/client/client.py", line 298, in graphql
result = <http://self.post|self.post>(
File "/usr/local/lib/python3.8/site-packages/prefect/client/client.py", line 213, in post
response = self._request(
File "/usr/local/lib/python3.8/site-packages/prefect/client/client.py", line 459, in _request
response = self._send_request(
File "/usr/local/lib/python3.8/site-packages/prefect/client/client.py", line 351, in _send_request
response = <http://session.post|session.post>(
File "/usr/local/lib/python3.8/site-packages/requests/sessions.py", line 590, in post
return self.request('POST', url, data=data, json=json, **kwargs)
File "/usr/local/lib/python3.8/site-packages/requests/sessions.py", line 542, in request
resp = self.send(prep, **send_kwargs)
File "/usr/local/lib/python3.8/site-packages/requests/sessions.py", line 655, in send
r = adapter.send(request, **kwargs)
File "/usr/local/lib/python3.8/site-packages/requests/adapters.py", line 516, in send
raise ConnectionError(e, request=request)
requests.exceptions.ConnectionError: HTTPConnectionPool(host='34.105.133.228', port=4200): Max retries exceeded with url: /graphql/graphql (Caused by NewConnectionError('<urllib3.connection.HTTPConnection object at 0x7fd4b2539df0>: Failed to establish a new connection: [Errno 104] Connection reset by peer'))
nicholas
03/16/2021, 11:20 PMMax retries exceeded with url: /graphql/graphql
- that's not a valid endpoint as far as I knowJosh Greenhalgh
03/16/2021, 11:47 PMnicholas
03/16/2021, 11:48 PMJosh Greenhalgh
03/16/2021, 11:49 PMnicholas
03/16/2021, 11:55 PMJosh Greenhalgh
03/16/2021, 11:58 PMnicholas
03/16/2021, 11:58 PMJosh Greenhalgh
03/17/2021, 10:54 AMAdam Brusselback
03/17/2021, 4:41 PMJosh Greenhalgh
03/17/2021, 4:42 PMMariia Kerimova
03/18/2021, 3:25 PMJosh Greenhalgh
03/18/2021, 5:08 PMMariia Kerimova
03/18/2021, 5:25 PMJosh Greenhalgh
03/18/2021, 5:33 PMMariia Kerimova
03/18/2021, 5:37 PMJosh Greenhalgh
03/18/2021, 5:37 PMprefect-agent-b48754c7-phlpf 1/1 Running 0 27h
prefect-server-apollo-664847899-bps5g 1/1 Running 0 4h15m
prefect-server-apollo-664847899-dsmzx 1/1 Running 0 4h16m
prefect-server-apollo-664847899-l5q6r 1/1 Running 0 3h22m
prefect-server-apollo-664847899-p88zt 1/1 Running 0 3h56m
prefect-server-graphql-54c7877659-7mmz6 1/1 Running 0 3h22m
prefect-server-graphql-54c7877659-gf7f5 1/1 Running 0 4h15m
prefect-server-graphql-54c7877659-x82lz 1/1 Running 0 4h16m
prefect-server-graphql-54c7877659-x947p 1/1 Running 0 3h56m
prefect-server-hasura-768f675d98-jt9qt 1/1 Running 0 23h
prefect-server-postgresql-0 1/1 Running 0 27h
prefect-server-towel-6f9b7bd98c-jr5d5 1/1 Running 0 23h
prefect-server-ui-5785c45564-5l9cq 1/1 Running 0 23h
Checking GraphQL service at <http://prefect-server-graphql.prefect:4201/health> ...
{"status":"ok","version":"2021.02.22"}
GraphQL service healthy!
> @ serve /apollo
> node dist/index.js
Building schema...
Building schema complete!
Server ready at <http://0.0.0.0:4200> š (version: 2021.02.22)
with Flow("weather_data_etl") as flow:
extract_date = Parameter("extract_date", default=None)
extract_period_days = Parameter("extract_period_days", default=None)
asset_filters = Parameter("asset_filters", default=None)
asset_limit = Parameter("asset_limit", default=None)
sql = parameterise_sql(asset_filters=asset_filters, asset_limit=asset_limit)
asset_locations = get_locations(sql=sql)
raw = extract_raw_from_api.map(
asset_location=asset_locations,
extract_date=unmapped(extract_date),
extract_period_days=unmapped(extract_period_days),
)
daily_data = process_daily_data.map(raw=raw, asset_location=asset_locations)
hourly_data = process_hourly_data.map(raw=raw, asset_location=asset_locations)
merged = merge_daily_hourly.map(daily_data=daily_data, hourly_data=hourly_data)
df = load_result(data=merged)
asset_locations
is currently of size 70 but need it to get much biggerMariia Kerimova
03/18/2021, 6:43 PMJosh Greenhalgh
03/18/2021, 6:48 PMMariia Kerimova
03/18/2021, 8:13 PMJosh Greenhalgh
03/24/2021, 2:52 PMMariia Kerimova
03/24/2021, 2:54 PMJosh Greenhalgh
03/24/2021, 2:55 PM