- retry 1: - flow filters the list, leaving 1 file to process - flow iterates over the filtered list, but does not call task - flow finishes in state
I’m guessing task is not called on the retry because the result has been cached and there is no reason to try again. That’s fine. However, I expected the final state of the task to be
. Is this behaving as intended?
- this happend for tasks being run in parallel via the dask
No heartbeat detected from the remote task; marking the run as failed
looking at our (internal) logs - it seems like all of them died simultaneously, 20+ minutes into their run there’s a total of 58 tasks being run, with 4 workers the first 4 tasks took approx. 1 hour to run and completed successfully, and then the next 4 that were run all seem to have failed simultaneously any idea / help?
that's in the flow's directory, and when I run
prefect deployment create deployment.py
ModuleNotFoundError: No module named 'tutorial'
What (if anything) do I pass to the merge function?
with case(cond, True): val1_if_true = action1_if_true() val2_if_true = action2_if_true() with case(cond, False): val_if_false = action_if_false()
I used following command to install elasticsearch client
Traceback (most recent call last): File "/Users/sabirali/PycharmProjects/ETL/ElasticSearchClientTest.py", line 5, in <module> print(<http://client.info|client.info>()) File "/Users/sabirali/PycharmProjects/ETL/venv/lib/python3.8/site-packages/elasticsearch/_sync/client/utils.py", line 414, in wrapped return api(*args, **kwargs) File "/Users/sabirali/PycharmProjects/ETL/venv/lib/python3.8/site-packages/elasticsearch/_sync/client/__init__.py", line 2277, in info return self.perform_request( # type: ignore[return-value] File "/Users/sabirali/PycharmProjects/ETL/venv/lib/python3.8/site-packages/elasticsearch/_sync/client/_base.py", line 332, in perform_request raise UnsupportedProductError( elasticsearch.UnsupportedProductError: The client noticed that the server is not Elasticsearch and we do not support this unknown product
(venv) sabirali@Sabirs-MacBook-Pro ETL % pip install elasticsearch Collecting elasticsearch Using cached elasticsearch-8.3.1-py3-none-any.whl (382 kB) Requirement already satisfied: elastic-transport<9,>=8 in ./venv/lib/python3.8/site-packages (from elasticsearch) (8.1.2) Requirement already satisfied: urllib3<2,>=1.26.2 in ./venv/lib/python3.8/site-packages (from elastic-transport<9,>=8->elasticsearch) (1.26.9) Requirement already satisfied: certifi in ./venv/lib/python3.8/site-packages (from elastic-transport<9,>=8->elasticsearch) (2022.6.15) Installing collected packages: elasticsearch Successfully installed elasticsearch-8.3.1 WARNING: You are using pip version 21.3.1; however, version 22.1.2 is available. You should consider upgrading via the '/Users/sabirali/PycharmProjects/ETL/venv/bin/python -m pip install --upgrade pip' command. (venv) sabirali@Sabirs-MacBook-Pro ETL %