SamSinayoko
06/01/2020, 7:16 AM(dagster) $ DAGSTER_HOME=$PWD dagster pipeline backfill -y repository.yaml
Select a pipeline to backfill: compute_total_stock_volume: compute_total_stock_volume
Pipeline: compute_total_stock_volume
Partition set: stock_data_partitions_set
Partitions:
2018-01-01 2018-02-01 2018-03-01 2018-04-01 2018-05-01 2018-06-01 2018-07-01 2018-08-01
2018-09-01 2018-10-01 2018-11-01 2018-12-01
Do you want to proceed with the backfill (12 partitions)? [y/N]: y
Launching runs...
Traceback (most recent call last):
File "/Users/sinayoks/apps/miniconda3/envs/dagster/bin/dagster", line 8, in <module>
sys.exit(main())
File "/Users/sinayoks/apps/miniconda3/envs/dagster/lib/python3.6/site-packages/dagster/cli/__init__.py", line 38, in main
cli(obj={}) # pylint:disable=E1123
File "/Users/sinayoks/apps/miniconda3/envs/dagster/lib/python3.6/site-packages/click/core.py", line 829, in __call__
return self.main(*args, **kwargs)
File "/Users/sinayoks/apps/miniconda3/envs/dagster/lib/python3.6/site-packages/click/core.py", line 782, in main
rv = self.invoke(ctx)
File "/Users/sinayoks/apps/miniconda3/envs/dagster/lib/python3.6/site-packages/click/core.py", line 1259, in invoke
return _process_result(sub_ctx.command.invoke(sub_ctx))
File "/Users/sinayoks/apps/miniconda3/envs/dagster/lib/python3.6/site-packages/click/core.py", line 1259, in invoke
return _process_result(sub_ctx.command.invoke(sub_ctx))
File "/Users/sinayoks/apps/miniconda3/envs/dagster/lib/python3.6/site-packages/click/core.py", line 1066, in invoke
return ctx.invoke(self.callback, **ctx.params)
File "/Users/sinayoks/apps/miniconda3/envs/dagster/lib/python3.6/site-packages/click/core.py", line 610, in invoke
return callback(*args, **kwargs)
File "/Users/sinayoks/apps/miniconda3/envs/dagster/lib/python3.6/site-packages/dagster/cli/pipeline.py", line 599, in pipeline_backfill_command
execute_backfill_command(kwargs, click.echo)
File "/Users/sinayoks/apps/miniconda3/envs/dagster/lib/python3.6/site-packages/dagster/cli/pipeline.py", line 693, in execute_backfill_command
instance.launch_run(run.run_id)
File "/Users/sinayoks/apps/miniconda3/envs/dagster/lib/python3.6/site-packages/dagster/core/instance/__init__.py", line 801, in launch_run
return self._run_launcher.launch_run(self, run)
File "/Users/sinayoks/apps/miniconda3/envs/dagster/lib/python3.6/site-packages/dagster_graphql/launcher/__init__.py", line 97, in launch_run
cls=self.__class__.__name__, address=self._address, result=result
dagster.core.errors.DagsterLaunchFailedError: Failed to launch run with RemoteDagitRunLauncher targeting <http://127.0.0.1:3000>:
{'__typename': 'PipelineRunNotFoundError'}
So it looks like the job is creating a run but Dagit isn't able to find it. Any idea what I'm doing wrong here?alex
06/01/2020, 1:37 PMdagit
you have running was not booted with the same repository.yaml
edit: I misread this thought it was PipelineNotFoundError
- as max comments below you need to make sure you are using the same DagsterInstance
in both which can be done by setting DAGSTER_HOME
env varSamSinayoko
06/01/2020, 3:40 PMSamSinayoko
06/01/2020, 3:40 PMrun_launcher:
module: dagster_graphql.launcher
class: RemoteDagitRunLauncher
config:
address: "<http://127.0.0.1:3000>"
SamSinayoko
06/01/2020, 3:41 PMrepository:
module: repository
fn: define_repo
pipeline: compute_total_stock_volume
alex
06/01/2020, 4:03 PMmax
06/01/2020, 4:51 PMDAGIT_HOME
env variableSamSinayoko
06/01/2020, 5:24 PMmax
06/01/2020, 5:25 PMalex
06/01/2020, 5:26 PMDAGSTER_HOME
set https://docs.dagster.io/docs/deploying/instance ?max
06/01/2020, 5:26 PMDAGIT_HOME
in one incantation and DAGSTER_HOME
in anothermax
06/01/2020, 5:26 PMDAGSTER_HOME
SamSinayoko
06/01/2020, 5:28 PMSamSinayoko
06/01/2020, 5:30 PMalex
06/01/2020, 5:34 PMSamSinayoko
06/01/2020, 5:35 PM