Ryan Tam
06/01/2020, 7:29 PMMuthu
06/01/2020, 7:59 PM/
…
i want to run the dagit like: <http://localhost:3000/engine>
Binh Pham
06/01/2020, 8:00 PMTravis Cline
06/01/2020, 10:07 PMTravis Cline
06/01/2020, 10:12 PMTravis Cline
06/01/2020, 10:12 PMBinh Pham
06/02/2020, 11:39 PMsephi
06/03/2020, 6:53 AM@composite_solid(
output_defs=[OutputDefinition(name='path', dagster_type=String),
OutputDefinition(name='dataframe', dagster_type=DataFrame),
])
def my_solid():
...
path = solid_return_path()
dataframe = solid_return_dataframe()
yield Output (path, 'path')
yield Output (dataframe, 'dataframe')we get the following error:
dagster.core.errors.DagsterInvalidDefinitionError: @composite_solid my_solid returned problematic value of type <class 'generator'>. Expected return value from invoked solid or dict mapping output name to return values from invoked solids.If we change it to :
return path, dataframethe pipeline runs. Any suggestions?
Sam Rausser
06/04/2020, 2:22 AMSam Rausser
06/04/2020, 2:23 AMSam Rausser
06/04/2020, 2:23 AMmax
06/04/2020, 2:28 AManderson
06/04/2020, 1:30 PMSam Rausser
06/04/2020, 2:38 PMSam Rausser
06/04/2020, 2:39 PMcompute_logs:
module: dagster.core.storage.local_compute_log_manager
class: NoOpComputeLogManager
config:
base_dir: /tmp/datafarm
user
06/04/2020, 11:33 PMprha
06/04/2020, 11:40 PMSam Rausser
06/05/2020, 12:23 AM0.7.16
Sam Rausser
06/05/2020, 12:23 AMSam Rausser
06/05/2020, 12:26 AMSam Rausser
06/05/2020, 12:26 AMSam Rausser
06/05/2020, 1:35 AMSam Rausser
06/05/2020, 1:35 AMSam Rausser
06/05/2020, 1:36 AMAndrey Alekseev
06/05/2020, 5:19 PMMuthu
06/05/2020, 7:45 PMsqlalchemy.exc.ProgrammingError: (psycopg2.errors.UndefinedColumn) column "snapshot_id" of relation "runs" does not exist
LINE 1: INSERT INTO runs (run_id, snapshot_id, pipeline_name, status...
VK
06/06/2020, 6:55 AMVK
06/06/2020, 6:56 AMwbonelli
06/06/2020, 7:22 PMexecute_pipeline_iterator
to send logs to the event stream?David
06/07/2020, 3:56 PM