ARun
09/03/2020, 12:34 PMClientError: Malformed response received from Cloud - please ensure that you have an API token properly configured.
Is there another token I need to configure?Jenny
09/03/2020, 1:15 PMARun
09/03/2020, 1:26 PMClientError: [{'path': ['project'], 'message': 'field "project" not found in type: \'query_root\'', 'extensions': {'path': '$.selectionSet.project', 'code': 'validation-failed', 'exception': {'message': 'field "project" not found in type: \'query_root\''}}}]
Jenny
09/03/2020, 1:28 PMprefect auth login -t PERSONALACCESSTOKEN
where PERSONALACCESSTOKEN is a Personal Access Token from the User page of the UI?ARun
09/03/2020, 3:04 PMTypeError: cannot pickle '_thread.lock' object
def runSql(sql, name=None):
cs.execute(sql)
with Flow('run') as flow:
runSql("USE ROLE SYSADMIN")
flow.register(project_name="test")
c:\python38\lib\site-packages\prefect\core\flow.py in register(self, project_name, build, labels, set_schedule_active, version_group_id, no_url, **kwargs)
1586 client = prefect.Client()
1587
-> 1588 registered_flow = client.register(
1589 flow=self,
1590 build=build,
c:\python38\lib\site-packages\prefect\client\client.py in register(self, flow, project_name, build, set_schedule_active, version_group_id, compressed, no_url)
732 )
733
--> 734 serialized_flow = flow.serialize(build=build) # type: Any
735
736 # Set Docker storage image in environment metadata if provided
c:\python38\lib\site-packages\prefect\core\flow.py in serialize(self, build)
1429 raise ValueError("This flow has no storage to build")
1430 if self.name not in self.storage:
-> 1431 self.storage.add_flow(self)
1432 else:
1433 warnings.warn(
c:\python38\lib\site-packages\prefect\environments\storage\local.py in add_flow(self, flow)
131 self.directory, "{}.prefect".format(slugify(flow.name))
132 )
--> 133 flow_location = flow.save(flow_location)
134
135 self.flows[flow.name] = flow_location
c:\python38\lib\site-packages\prefect\core\flow.py in save(self, fpath)
1498 fpath.parent.mkdir(exist_ok=True, parents=True)
1499 with open(str(fpath), "wb") as f:
-> 1500 cloudpickle.dump(self, f)
1501
1502 return str(fpath)
c:\python38\lib\site-packages\cloudpickle\cloudpickle_fast.py in dump(obj, file, protocol, buffer_callback)
53 compatibility with older versions of Python.
54 """
---> 55 CloudPickler(
56 file, protocol=protocol, buffer_callback=buffer_callback
57 ).dump(obj)
c:\python38\lib\site-packages\cloudpickle\cloudpickle_fast.py in dump(self, obj)
561 def dump(self, obj):
562 try:
--> 563 return Pickler.dump(self, obj)
564 except RuntimeError as e:
565 if "recursion" in e.args[0]:
TypeError: cannot pickle '_thread.lock' object
Jenny
09/03/2020, 3:45 PM