https://flyte.org logo
#introductions
Title
# introductions
b

Brandon Segal

01/02/2022, 6:33 PM
Hi! I’m Brandon Segal an Analytics Engineer over at Spotify looking to migrate some of our workflows from Luigi to Flyte! If anyone has experience using flyte with GCP workloads and big query I’d love to hear more about how you did that!
k

Ketan (kumare3)

01/02/2022, 6:52 PM
Hi @Brandon Segal - happy new year and welcome to the community
Brandon any specific questions?
b

Brandon Segal

01/02/2022, 9:23 PM
So I’ve been able to wrap my head around the base case when authoring tasks and workflows with flyte kit. I’ve had a little bit of an issue understanding how to take advantage of backend plugins installed on flyte propeller that don’t have corresponding tasks in flyte kit. Is that a case where we would use a reference task to take advantage of these. In particular I’m asking in regards to the bigquery plugin since a majority of my workflows would involve checking for some table or expectation in bigquery
k

Ketan (kumare3)

01/03/2022, 1:23 AM
@Brandon Segal usually a backend plugin should have a flytekit task. Reference tasks are useful to refer to a previously implemented functionality
As for big query … cc @Guillaume Perchais / @Viktor Gerdin , but @Kevin Su just completed implementation of bigquery python flytekit shim https://github.com/flyteorg/flytekit/pull/789
b

Brandon Segal

01/03/2022, 1:51 PM
Ahhh gotcha. So I would use a reference task to incorporate some task that is deployed already to flyte that may have been written by another team. In regards to bigquery, I could write a collection of SQLAlchemy tasks which handle the connection and query the services until this shim is pulled in?
k

Ketan (kumare3)

01/03/2022, 2:31 PM
That should work. Performance of the shim is better though
7 Views