def upload_pyspark_file(project_id, bucket_name, filename, file):
 print 'Uploading pyspark file to GCS'
 client = storage.Client(project=project_id)
 bucket = client.get_bucket(bucket_name)
 blob = bucket.blob(filename)
 blob.upload_from_file(file)

def upload_pyspark_file ( project_id , bucket_name , filename , file ) : print 'Uploading pyspark file to GCS' client = storage . Client ( project = project_id ) bucket = client . get_bucket ( bucket_name ) blob = bucket . blob ( filename ) blob . upload_from_file ( file )
uploads the pyspark file in this directory to the configured input bucket .