Mycchaka Kleinbort
05/17/2023, 3:36 PMTim Castillo
05/17/2023, 4:55 PMquery GetLineage {
assetNodes {
assetKey {
path
}
dependedBy {
asset {
assetKey {
path
}
}
}
dependencies {
asset {
assetKey {
path
}
}
}
}
}
Mycchaka Kleinbort
05/17/2023, 5:04 PMMoody Edghaim
05/17/2023, 5:12 PMTim Castillo
05/17/2023, 5:13 PMMycchaka Kleinbort
05/17/2023, 5:16 PMfrom dagster_graphql import DagsterGraphQLClient
import dagster
import warnings
warnings.filterwarnings("ignore", category=dagster.ExperimentalWarning)
gql_client = DagsterGraphQLClient('localhost', port_number=3000)
q = '''
query GetLineage {
assetNodes {
assetKey {
path
}
dependedBy {
asset {
assetKey {
path
}
}
}
dependencies {
asset {
assetKey {
path
}
}
}
}
}
'''
Just trying to figure out how to run the queryTim Castillo
05/17/2023, 5:19 PMDagsterGraphQLClient
is a wrapper that runs specific pre-made queries. If you'd like to query the endpoint on your own outside of Dagster, ( such as in another python script or a notebook), then you can copy+paste the python code in the gist I sent you and install its dependencies.Mycchaka Kleinbort
05/18/2023, 8:58 AM